[
https://issues.apache.org/jira/browse/FLINK-20337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17240799#comment-17240799
]
Aljoscha Krettek commented on FLINK-20337:
------------------------------------------
master: da1ad03d68e6c57a95d7375259247053aa8fc24e and commits around it.
> Allow stateful migration from StreamingFileSink to FileSink
> ------------------------------------------------------------
>
> Key: FLINK-20337
> URL: https://issues.apache.org/jira/browse/FLINK-20337
> Project: Flink
> Issue Type: Improvement
> Components: API / DataStream
> Affects Versions: 1.12.0
> Reporter: Guowei Ma
> Assignee: Guowei Ma
> Priority: Critical
> Fix For: 1.12.0
>
>
> Flink-1.12 introduces the `FileSink` in FLINK-19510, which can guarantee the
> exactly once semantics both in the streaming and batch execution mode. We
> need to provide a way for the user who uses `StreamingFileSink` to migrate
> from `StreamingFileSink` to `FileSink`.
> For this purpose we propose to let the new sink writer operator could load
> the previous StreamingFileSink's state and then the `SinkWriter` could have
> the opertunity to handle the old state.
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
