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 c0250c745d Hive: Fix lock selection during table creation to respect
table properties (#14236)
add 911a486b0e Flink: Prevent recreation of ManifestOutputFileFactory
during flushing (#14358)
No new revisions were added by this update.
Summary of changes:
flink/v2.1/build.gradle | 3 -
.../iceberg/flink/sink/FlinkManifestUtil.java | 14 ++-
.../flink/sink/ManifestOutputFileFactory.java | 11 +-
.../flink/sink/dynamic/DynamicIcebergSink.java | 2 +-
.../sink/dynamic/DynamicWriteResultAggregator.java | 34 ++++---
.../iceberg/flink/sink/dynamic/DynamicWriter.java | 5 +
.../iceberg/flink/sink/TestFlinkManifest.java | 2 +-
.../flink/sink/TestManifestOutputFileFactory.java | 112 +++++++++++++++++++++
.../flink/sink/dynamic/TestDynamicCommitter.java | 12 ++-
.../dynamic/TestDynamicWriteResultAggregator.java | 92 ++++++++++++++++-
.../flink/sink/dynamic/TestDynamicWriter.java | 32 ++++++
11 files changed, 290 insertions(+), 29 deletions(-)
create mode 100644
flink/v2.1/flink/src/test/java/org/apache/iceberg/flink/sink/TestManifestOutputFileFactory.java
