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)