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 bea364c36f Introduces the new IcebergSink based on the new V2 Flink
Sink Abstraction (#10179)
add e6f8ab9950 Flink: Backport PR #10179 to Flink 1.20 for v2 sink
(#11011)
No new revisions were added by this update.
Summary of changes:
.../iceberg/flink/sink/FlinkManifestUtil.java | 27 +++++++++++
.../org/apache/iceberg/flink/sink/FlinkSink.java | 3 +-
.../iceberg/flink/sink/IcebergCommittable.java | 0
.../flink/sink/IcebergCommittableSerializer.java | 0
.../iceberg/flink/sink/IcebergCommitter.java | 0
.../iceberg/flink/sink/IcebergFilesCommitter.java | 51 +--------------------
.../org/apache/iceberg/flink/sink/IcebergSink.java | 0
.../iceberg/flink/sink/IcebergSinkWriter.java | 0
.../iceberg/flink/sink/IcebergStreamWriter.java | 6 +--
.../iceberg/flink/sink/IcebergWriteAggregator.java | 0
.../flink/sink/ManifestOutputFileFactory.java | 4 +-
.../org/apache/iceberg/flink/sink/SinkUtil.java | 0
.../iceberg/flink/sink/WriteResultSerializer.java | 0
.../apache/iceberg/flink/sink/SinkTestUtil.java | 0
.../flink/sink/TestFlinkIcebergSinkV2Base.java | 52 +++++++++++-----------
.../flink/sink/TestFlinkIcebergSinkV2Branch.java | 2 +-
.../iceberg/flink/sink/TestFlinkManifest.java | 5 ++-
.../iceberg/flink/sink/TestIcebergCommitter.java | 0
.../flink/sink/TestIcebergFilesCommitter.java | 7 ++-
.../apache/iceberg/flink/sink/TestIcebergSink.java | 0
.../iceberg/flink/sink/TestIcebergSinkBranch.java | 0
.../iceberg/flink/sink/TestIcebergSinkV2.java | 0
.../flink/sink/TestIcebergSinkV2Branch.java | 0
23 files changed, 69 insertions(+), 88 deletions(-)
copy flink/{v1.19 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergCommittable.java
(100%)
copy flink/{v1.19 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergCommittableSerializer.java
(100%)
copy flink/{v1.19 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergCommitter.java
(100%)
copy flink/{v1.19 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergSink.java (100%)
copy flink/{v1.19 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergSinkWriter.java
(100%)
copy flink/{v1.19 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergWriteAggregator.java
(100%)
copy flink/{v1.19 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/sink/SinkUtil.java (100%)
copy flink/{v1.19 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/sink/WriteResultSerializer.java
(100%)
copy flink/{v1.19 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/sink/SinkTestUtil.java
(100%)
copy flink/{v1.19 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/sink/TestIcebergCommitter.java
(100%)
copy flink/{v1.19 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/sink/TestIcebergSink.java
(100%)
copy flink/{v1.19 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/sink/TestIcebergSinkBranch.java
(100%)
copy flink/{v1.19 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/sink/TestIcebergSinkV2.java
(100%)
copy flink/{v1.19 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/sink/TestIcebergSinkV2Branch.java
(100%)
