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/25 08:34:15 UTC
(iceberg) branch main updated (bcb68800e1 -> 522de0fe83)

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 bcb68800e1 Core: Fix filed ids of partition stats file (#13329)
     add 522de0fe83 Flink: Migrate Flink `TableSchema` to `Schema`/`ResolvedSchema` (#13072)

No new revisions were added by this update.

Summary of changes:
 LICENSE                                            |   1 +
 .../org/apache/iceberg/flink/FlinkCatalog.java     |  36 +--
 .../iceberg/flink/FlinkDynamicTableFactory.java    |  23 +-
 .../org/apache/iceberg/flink/FlinkSchemaUtil.java  | 158 +++++++++++-
 .../org/apache/iceberg/flink/IcebergTableSink.java | 115 ++++++---
 .../org/apache/iceberg/flink/sink/FlinkSink.java   |  62 ++++-
 .../org/apache/iceberg/flink/sink/IcebergSink.java |  72 +++++-
 .../iceberg/flink/sink/IcebergSinkBuilder.java     |  20 ++
 .../apache/iceberg/flink/source/IcebergSource.java |  18 +-
 .../iceberg/flink/source/IcebergTableSource.java   |  27 +-
 .../iceberg/flink/source/reader/RowConverter.java  |  12 +-
 .../iceberg/flink/util/FlinkCompatibilityUtil.java |   9 +
 .../org/apache/iceberg/flink/SimpleDataUtil.java   |  12 +-
 .../iceberg/flink/TestFlinkCatalogTable.java       |  11 +-
 .../org/apache/iceberg/flink/TestFlinkFilters.java |  53 ++--
 .../apache/iceberg/flink/TestFlinkSchemaUtil.java  | 226 ++++++++++-------
 .../apache/iceberg/flink/TestFlinkTableSink.java   |   2 +-
 .../flink/TestFlinkTableSinkCompaction.java        |  10 +-
 .../TestBucketPartitionerFlinkIcebergSink.java     |  10 +-
 .../flink/sink/TestCompressionSettings.java        |   6 +-
 .../iceberg/flink/sink/TestFlinkIcebergSink.java   |  50 ++--
 .../flink/sink/TestFlinkIcebergSinkBase.java       |  41 +++-
 .../flink/sink/TestFlinkIcebergSinkBranch.java     |  49 ++--
 .../sink/TestFlinkIcebergSinkDistributionMode.java | 158 ++++++++----
 .../flink/sink/TestFlinkIcebergSinkExtended.java   |  90 +++++--
 .../iceberg/flink/sink/TestFlinkIcebergSinkV2.java |  22 +-
 .../flink/sink/TestFlinkIcebergSinkV2Base.java     |  79 ++++--
 .../flink/sink/TestFlinkIcebergSinkV2Branch.java   |  17 +-
 .../TestFlinkIcebergSinkV2DistributionMode.java    | 179 ++++++++++----
 .../apache/iceberg/flink/sink/TestIcebergSink.java | 272 ++++++++++++++-------
 .../iceberg/flink/sink/TestIcebergSinkBranch.java  |  42 +++-
 .../iceberg/flink/sink/TestIcebergSinkV2.java      |  52 ++--
 .../flink/sink/TestIcebergStreamWriter.java        |  16 +-
 .../apache/iceberg/flink/sink/TestTaskWriters.java |   3 +-
 .../flink/sink/dynamic/TestDynamicIcebergSink.java |   8 +-
 .../iceberg/flink/source/BoundedTableFactory.java  |  40 ++-
 .../flink/source/TestIcebergSourceBounded.java     |  33 ++-
 .../flink/source/TestIcebergSourceBoundedRow.java  |  12 +-
 38 files changed, 1478 insertions(+), 568 deletions(-)