[jira] [Created] (FLINK-14868) Provides the ability for multiple sinks to write data serially

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-14868) Provides the ability for multiple sinks to write data serially

Shang Yuanchun (Jira)
ShenDa created FLINK-14868:
------------------------------

             Summary: Provides the ability for multiple sinks to write data serially
                 Key: FLINK-14868
                 URL: https://issues.apache.org/jira/browse/FLINK-14868
             Project: Flink
          Issue Type: Wish
          Components: API / DataStream, Table SQL / Runtime
    Affects Versions: 1.9.1
            Reporter: ShenDa
             Fix For: 1.9.2


At present, Flink can use multiple sinks to write data into different data source such as HBase,Kafka,Elasticsearch,etc.And this process is concurrent ,in other words, one record will be written into data sources simultaneously.

But there is no approach that can sinking data serially.We really wish Flink can providing this kind of ability that a sink can write data into target database only after the previous sink transfers data successfully.And if the previous sink encounters any exception, the next sink will not work.
h1.  



--
This message was sent by Atlassian Jira
(v8.3.4#803005)