You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iceberg.apache.org by st...@apache.org on 2023/05/18 13:44:17 UTC
[iceberg] branch master updated (477da36e3f -> 67decf90d9)

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 477da36e3f Flink: backport Add config for max allowed consecutive planning failures in IcebergSource before failing the job (#7571) to 1.16 and 1.15 (#7629)
     add 67decf90d9 Flink: backport PR #7494. change sink shuffle to use RowData as data type and statistics key type (#7632)

No new revisions were added by this update.

Summary of changes:
 .../iceberg/flink/sink/shuffle/DataStatistics.java |  18 +-
 .../flink/sink/shuffle/DataStatisticsEvent.java    |   8 +-
 .../flink/sink/shuffle/DataStatisticsFactory.java  |  33 ----
 .../flink/sink/shuffle/DataStatisticsOperator.java |  51 +++---
 .../flink/sink/shuffle/DataStatisticsOrRecord.java |  53 ++++--
 .../shuffle/DataStatisticsOrRecordSerializer.java  |   0
 .../flink/sink/shuffle/MapDataStatistics.java      |  27 +--
 .../sink/shuffle/MapDataStatisticsFactory.java     |  34 ----
 .../sink/shuffle/MapDataStatisticsSerializer.java  |   0
 .../sink/shuffle/TestDataStatisticsOperator.java   | 186 ++++++++++++---------
 .../iceberg/flink/sink/shuffle/DataStatistics.java |  18 +-
 .../flink/sink/shuffle/DataStatisticsEvent.java    |   8 +-
 .../flink/sink/shuffle/DataStatisticsFactory.java  |  33 ----
 .../flink/sink/shuffle/DataStatisticsOperator.java |  51 +++---
 .../flink/sink/shuffle/DataStatisticsOrRecord.java |  53 ++++--
 .../shuffle/DataStatisticsOrRecordSerializer.java  |   0
 .../flink/sink/shuffle/MapDataStatistics.java      |  27 +--
 .../sink/shuffle/MapDataStatisticsFactory.java     |  34 ----
 .../sink/shuffle/MapDataStatisticsSerializer.java  |   0
 .../sink/shuffle/TestDataStatisticsOperator.java   | 186 ++++++++++++---------
 20 files changed, 414 insertions(+), 406 deletions(-)
 delete mode 100644 flink/v1.15/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/DataStatisticsFactory.java
 copy flink/{v1.17 => v1.15}/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/DataStatisticsOrRecordSerializer.java (100%)
 delete mode 100644 flink/v1.15/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/MapDataStatisticsFactory.java
 copy flink/{v1.17 => v1.15}/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/MapDataStatisticsSerializer.java (100%)
 delete mode 100644 flink/v1.16/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/DataStatisticsFactory.java
 copy flink/{v1.17 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/DataStatisticsOrRecordSerializer.java (100%)
 delete mode 100644 flink/v1.16/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/MapDataStatisticsFactory.java
 copy flink/{v1.17 => v1.16}/flink/src/main/java/org/apache/iceberg/flink/sink/shuffle/MapDataStatisticsSerializer.java (100%)