[jira] [Created] (FLINK-20031) Keep the uid of SinkWriter same as the SinkTransformation

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

[jira] [Created] (FLINK-20031) Keep the uid of SinkWriter same as the SinkTransformation

Shang Yuanchun (Jira)
Guowei Ma created FLINK-20031:
---------------------------------

             Summary: Keep the uid of SinkWriter same as the SinkTransformation
                 Key: FLINK-20031
                 URL: https://issues.apache.org/jira/browse/FLINK-20031
             Project: Flink
          Issue Type: Sub-task
          Components: API / DataStream
            Reporter: Guowei Ma


In this case that we want to migrate the StreamingFileSink to the new sink api we might need to let user set the SinkWriter's uid same as the StreamingFileSink's. So that SinkWriter operator has the opportunity to reuse the old state. (This is just a option.)

 

For this we need to let SinkWriter operator's uid is the same as the SinkTransformation.

 



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