This is an automated email from the ASF dual-hosted git repository.
stevenwu pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/iceberg.git
from 1521296dd2 Core: Support lazy snapshot loading in TableMetadata (#6811)
add a7a6d354b1 Flink: Support branch writes in Flink sink (#6660)
No new revisions were added by this update.
Summary of changes:
.../org/apache/iceberg/flink/FlinkWriteConf.java | 8 +
.../apache/iceberg/flink/FlinkWriteOptions.java | 5 +
.../org/apache/iceberg/flink/sink/FlinkSink.java | 8 +-
.../iceberg/flink/sink/IcebergFilesCommitter.java | 16 +-
.../org/apache/iceberg/flink/SimpleDataUtil.java | 46 +-
.../iceberg/flink/sink/TestFlinkIcebergSink.java | 35 +-
.../flink/sink/TestFlinkIcebergSinkBase.java | 64 +++
.../flink/sink/TestFlinkIcebergSinkBranch.java | 137 ++++++
.../iceberg/flink/sink/TestFlinkIcebergSinkV2.java | 310 +------------
.../flink/sink/TestFlinkIcebergSinkV2Base.java} | 505 ++++++++-------------
.../flink/sink/TestFlinkIcebergSinkV2Branch.java | 134 ++++++
.../flink/sink/TestIcebergFilesCommitter.java | 87 ++--
12 files changed, 646 insertions(+), 709 deletions(-)
create mode 100644
flink/v1.16/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkIcebergSinkBase.java
create mode 100644
flink/v1.16/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkIcebergSinkBranch.java
copy
flink/{v1.14/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkIcebergSinkV2.java
=>
v1.16/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkIcebergSinkV2Base.java}
(62%)
create mode 100644
flink/v1.16/flink/src/test/java/org/apache/iceberg/flink/sink/TestFlinkIcebergSinkV2Branch.java
