This is an automated email from the ASF dual-hosted git repository.
gaoyunhaii pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from ed3b613 [hotfix] Improve language for error message when checkpoint
is declined due to some tasks being finished already.
add fdf40d2 [FLINK-24065][connector] Upgrade the state of
TwoPhaseCommitSink to support empty transaction after finished
No new revisions were added by this update.
Summary of changes:
.../functions/sink/TwoPhaseCommitSinkFunction.java | 102 ++++++++++++++++-----
.../sink/TwoPhaseCommitSinkFunctionTest.java | 40 +++++++-
...oPhaseCommitSinkStateSerializerUpgradeTest.java | 6 +-
3 files changed, 122 insertions(+), 26 deletions(-)
