This is an automated email from the ASF dual-hosted git repository.
stevenwu pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/iceberg.git
from 2ed61a12bf Flink: infer source parallelism for FLIP-27 source in batch
execution mode (#10832)
add a7398aba21 Flink: Fix duplicate data with upsert writer in case of
aborted checkpoints (#10526)
No new revisions were added by this update.
Summary of changes:
.../org/apache/iceberg/flink/sink/FlinkSink.java | 11 +-
.../iceberg/flink/sink/FlinkWriteResult.java | 24 ++-
.../iceberg/flink/sink/IcebergFilesCommitter.java | 48 +++--
.../iceberg/flink/sink/IcebergStreamWriter.java | 13 +-
.../flink/sink/TestCompressionSettings.java | 11 +-
.../flink/sink/TestIcebergFilesCommitter.java | 240 +++++++++++++++------
.../flink/sink/TestIcebergStreamWriter.java | 61 ++++--
7 files changed, 272 insertions(+), 136 deletions(-)
copy api/src/main/java/org/apache/iceberg/types/PrimitiveHolder.java =>
flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/sink/FlinkWriteResult.java
(63%)
