This is an automated email from the ASF dual-hosted git repository.
pvary pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/iceberg.git
from 2fe4495e97 Flink: Fix commit duplication in DynamicIcebergSink (#14517)
add 4ee507d578 Flink: DynamicSink support dvs (#14414)
No new revisions were added by this update.
Summary of changes:
docs/docs/flink-writes.md | 1 +
.../flink/sink/dynamic/DynamicCommitter.java | 20 +-
.../sink/dynamic/DynamicWriteResultAggregator.java | 36 ++--
.../iceberg/flink/sink/dynamic/DynamicWriter.java | 5 -
.../flink/sink/dynamic/TestDynamicCommitter.java | 137 ++++++++++++++
.../flink/sink/dynamic/TestDynamicIcebergSink.java | 205 +++++++++++++++++++++
6 files changed, 384 insertions(+), 20 deletions(-)
