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 2026/05/28 15:56:41 UTC

(iceberg) branch main updated (1a5b46cd02 -> e25cfe72d0)

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 1a5b46cd02 Core: Cache PartitionData template in PartitionsTable to avoid rebuilding Avro schema per partition (#16208)
     add e25cfe72d0 Flink: Backport honor schema identifier fields in dynamic-sink record routing (#16597)

No new revisions were added by this update.

Summary of changes:
 .../flink/sink/dynamic/DynamicRecordProcessor.java | 15 +++-
 .../flink/sink/dynamic/DynamicSinkUtil.java        | 15 ++++
 .../flink/sink/dynamic/HashKeyGenerator.java       | 17 ++--
 .../sink/dynamic/TestDynamicRecordProcessor.java   |  0
 .../flink/sink/dynamic/TestHashKeyGenerator.java   | 97 ++++++++++++++++++++++
 .../flink/sink/dynamic/DynamicRecordProcessor.java | 15 +++-
 .../flink/sink/dynamic/DynamicSinkUtil.java        | 15 ++++
 .../flink/sink/dynamic/HashKeyGenerator.java       | 17 ++--
 .../sink/dynamic/TestDynamicRecordProcessor.java   |  0
 .../flink/sink/dynamic/TestHashKeyGenerator.java   | 97 ++++++++++++++++++++++
 10 files changed, 272 insertions(+), 16 deletions(-)
 copy flink/{v2.1 => v1.20}/flink/src/test/java/org/apache/iceberg/flink/sink/dynamic/TestDynamicRecordProcessor.java (100%)
 copy flink/{v2.1 => v2.0}/flink/src/test/java/org/apache/iceberg/flink/sink/dynamic/TestDynamicRecordProcessor.java (100%)