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)
