This is an automated email from the ASF dual-hosted git repository.
mxm pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from d08abb7b169 [FLINK-37955] Add test for duplicated results from
StreamingJoinOperator
add 335621e598c [FLINK-38370] Ensure CommitterOperator commits all pending
committables in batch mode
No new revisions were added by this update.
Summary of changes:
.../runtime/operators/sink/CommitterOperator.java | 2 +-
.../sink/SinkV2CommitterOperatorTest.java | 45 ++++++++++++++++++++--
2 files changed, 43 insertions(+), 4 deletions(-)
