This is an automated email from the ASF dual-hosted git repository.
lzljs3620320 pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git
from d976fd062 [flink] Introduce partition mark done with batch (#3507)
add e8c2cc85b [flink] Remove endInput for commit method for partition mark
done
No new revisions were added by this update.
Summary of changes:
.../src/main/java/org/apache/paimon/flink/sink/Committer.java | 3 +--
.../java/org/apache/paimon/flink/sink/CommitterOperator.java | 4 ++--
.../main/java/org/apache/paimon/flink/sink/StoreCommitter.java | 6 +++---
.../java/org/apache/paimon/flink/sink/StoreMultiCommitter.java | 6 +++---
.../apache/paimon/flink/sink/partition/PartitionMarkDone.java | 10 +++++++---
.../paimon/flink/sink/partition/PartitionMarkDoneTrigger.java | 6 ++----
.../org/apache/paimon/flink/sink/CommitterOperatorTest.java | 2 +-
7 files changed, 19 insertions(+), 18 deletions(-)
