JingsongLi opened a new pull request, #538: URL: https://github.com/apache/flink-table-store/pull/538
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 is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
