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 2024/12/10 21:34:02 UTC

(iceberg) branch main updated (28e81809e6 -> ac6509a4e4)

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 28e81809e6 Core, Flink, Spark: Drop deprecated APIs scheduled for removal in 1.8.0 (#11721)
     add ac6509a4e4 Flink: Fix range distribution npe when value is null (#11662)

No new revisions were added by this update.

Summary of changes:
 .../flink/sink/shuffle/CompletedStatistics.java    | 17 +++++
 .../shuffle/CompletedStatisticsSerializer.java     | 12 ++++
 .../sink/shuffle/DataStatisticsCoordinator.java    |  3 +-
 .../flink/sink/shuffle/SortKeySerializer.java      | 65 ++++++++++++++++---
 .../iceberg/flink/sink/shuffle/StatisticsUtil.java | 25 ++++++--
 .../sink/TestFlinkIcebergSinkDistributionMode.java | 39 ++++++++++++
 .../shuffle/TestCompletedStatisticsSerializer.java | 49 ++++++++++++++
 .../shuffle/TestDataStatisticsCoordinator.java     | 74 ++++++++++++++++++++++
 .../sink/shuffle/TestDataStatisticsOperator.java   | 30 +++++++++
 .../shuffle/TestSortKeySerializerPrimitives.java   |  4 +-
 .../shuffle/TestSortKeySerializerSnapshot.java     | 22 +++++++
 11 files changed, 325 insertions(+), 15 deletions(-)