You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "Jingsong Lee (Jira)" <ji...@apache.org> on 2023/02/15 03:48:00 UTC

[jira] [Created] (FLINK-31072) Introduce streaming-read-atomic to ensure UB and UA cannot be split

Jingsong Lee created FLINK-31072:
------------------------------------

             Summary: Introduce streaming-read-atomic to ensure UB and UA cannot be split
                 Key: FLINK-31072
                 URL: https://issues.apache.org/jira/browse/FLINK-31072
             Project: Flink
          Issue Type: Improvement
            Reporter: Jingsong Lee


Currently, streaming source will be checkpoint in any time, this means UPDATE_BEFORE and UPDATE_AFTER can be split into two checkpoint.
Downstream can see intermediate state. This is weird in some cases.
So in this ticket, add streaming-read-atomic:
The option to enable return per iterator instead of per record in streaming read. This can ensure that there will be no checkpoint segmentation in iterator consumption.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)