You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iceberg.apache.org by pv...@apache.org on 2025/06/18 14:06:25 UTC
(iceberg) branch main updated (5b50afe8f2 -> 81b74fc0b9)

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 5b50afe8f2 Core, REST: Add context aware response parsing (#13191)
     add 81b74fc0b9 Flink: Backport dynamic Iceberg Sink: Add sink / core processing logic / benchmarking to Flink 1.19 / 1.20 (#13341)

No new revisions were added by this update.

Summary of changes:
 ...namicRecordSerializerDeserializerBenchmark.java |  0
 .../org/apache/iceberg/flink/FlinkConfParser.java  |  7 +++
 .../org/apache/iceberg/flink/FlinkWriteConf.java   |  4 ++
 .../org/apache/iceberg/flink/sink/FlinkSink.java   | 49 +-----------------
 .../org/apache/iceberg/flink/sink/IcebergSink.java | 49 +-----------------
 .../org/apache/iceberg/flink/sink/SinkUtil.java    | 59 +++++++++++++++++++++-
 .../flink/sink/dynamic/DynamicCommitter.java       |  3 +-
 .../flink/sink/dynamic/DynamicIcebergSink.java     |  4 +-
 .../flink/sink/dynamic/DynamicRecordGenerator.java |  0
 .../flink/sink/dynamic/DynamicRecordProcessor.java |  0
 .../flink/sink/dynamic/HashKeyGenerator.java       | 16 +++---
 .../org/apache/iceberg/flink/SimpleDataUtil.java   | 22 +++++++-
 .../java/org/apache/iceberg/flink/TestHelpers.java |  2 +-
 .../flink/sink/TestFlinkIcebergSinkBase.java       |  5 +-
 .../flink/sink/dynamic/TestDynamicIcebergSink.java |  2 +-
 .../sink/dynamic/TestDynamicIcebergSinkPerf.java   |  0
 ...namicRecordSerializerDeserializerBenchmark.java |  0
 .../org/apache/iceberg/flink/FlinkConfParser.java  |  7 +++
 .../org/apache/iceberg/flink/FlinkWriteConf.java   |  4 ++
 .../org/apache/iceberg/flink/sink/FlinkSink.java   | 49 +-----------------
 .../org/apache/iceberg/flink/sink/IcebergSink.java | 49 +-----------------
 .../org/apache/iceberg/flink/sink/SinkUtil.java    | 59 +++++++++++++++++++++-
 .../flink/sink/dynamic/DynamicCommitter.java       |  3 +-
 .../flink/sink/dynamic/DynamicIcebergSink.java     |  4 +-
 .../flink/sink/dynamic/DynamicRecordGenerator.java |  0
 .../flink/sink/dynamic/DynamicRecordProcessor.java |  0
 .../flink/sink/dynamic/HashKeyGenerator.java       | 16 +++---
 .../org/apache/iceberg/flink/SimpleDataUtil.java   | 22 +++++++-
 .../org/apache/iceberg/flink/TestFlinkFilters.java |  1 +
 .../java/org/apache/iceberg/flink/TestHelpers.java |  2 +-
 .../flink/sink/TestFlinkIcebergSinkBase.java       |  5 +-
 .../flink/sink/dynamic/TestDynamicIcebergSink.java |  2 +-
 .../sink/dynamic/TestDynamicIcebergSinkPerf.java   |  0
 33 files changed, 223 insertions(+), 222 deletions(-)
 copy flink/{v2.0 => v1.19}/flink/src/jmh/java/org/apache/iceberg/flink/sink/dynamic/DynamicRecordSerializerDeserializerBenchmark.java (100%)
 copy flink/{v2.0 => v1.19}/flink/src/main/java/org/apache/iceberg/flink/sink/dynamic/DynamicIcebergSink.java (99%)
 copy flink/{v2.0 => v1.19}/flink/src/main/java/org/apache/iceberg/flink/sink/dynamic/DynamicRecordGenerator.java (100%)
 copy flink/{v2.0 => v1.19}/flink/src/main/java/org/apache/iceberg/flink/sink/dynamic/DynamicRecordProcessor.java (100%)
 copy flink/{v2.0 => v1.19}/flink/src/test/java/org/apache/iceberg/flink/sink/dynamic/TestDynamicIcebergSink.java (99%)
 copy flink/{v2.0 => v1.19}/flink/src/test/java/org/apache/iceberg/flink/sink/dynamic/TestDynamicIcebergSinkPerf.java (100%)
 copy flink/{v2.0 => v1.20}/flink/src/jmh/java/org/apache/iceberg/flink/sink/dynamic/DynamicRecordSerializerDeserializerBenchmark.java (100%)
 copy flink/{v2.0 => v1.20}/flink/src/main/java/org/apache/iceberg/flink/sink/dynamic/DynamicIcebergSink.java (99%)
 copy flink/{v2.0 => v1.20}/flink/src/main/java/org/apache/iceberg/flink/sink/dynamic/DynamicRecordGenerator.java (100%)
 copy flink/{v2.0 => v1.20}/flink/src/main/java/org/apache/iceberg/flink/sink/dynamic/DynamicRecordProcessor.java (100%)
 copy flink/{v2.0 => v1.20}/flink/src/test/java/org/apache/iceberg/flink/sink/dynamic/TestDynamicIcebergSink.java (99%)
 copy flink/{v2.0 => v1.20}/flink/src/test/java/org/apache/iceberg/flink/sink/dynamic/TestDynamicIcebergSinkPerf.java (100%)