This is an automated email from the ASF dual-hosted git repository.
huaxingao pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/iceberg.git
from 6ee8252be4 Core: Implement refs snapshot mode in reference IRC (#14060)
add 441597e22e Flink: Backport #14182: Ensure DynamicCommitter Idempotence
in the presence of failures (#14213)
No new revisions were added by this update.
Summary of changes:
.../flink/sink/dynamic/DynamicCommitter.java | 55 ++-
.../flink/sink/dynamic/TestDynamicCommitter.java | 535 ++++++++++++++++++---
.../flink/sink/dynamic/TestDynamicIcebergSink.java | 92 +---
.../flink/sink/dynamic/DynamicCommitter.java | 55 ++-
.../flink/sink/dynamic/TestDynamicCommitter.java | 535 ++++++++++++++++++---
.../flink/sink/dynamic/TestDynamicIcebergSink.java | 92 +---
6 files changed, 990 insertions(+), 374 deletions(-)
