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 fce069f170 Spark 3.5: Fix row lineage inheritance for distributed
planning (#13061)
add c151c2dfa6 Flink: Backport optimised RowData evolution to Flink 1.19 /
1.20 (#13401)
No new revisions were added by this update.
Summary of changes:
.../iceberg/flink/sink/dynamic/DataConverter.java | 0
.../flink/sink/dynamic/DynamicIcebergSink.java | 25 +-
.../flink/sink/dynamic/DynamicRecordProcessor.java | 41 ++--
.../sink/dynamic/DynamicTableUpdateOperator.java | 28 ++-
.../iceberg/flink/sink/dynamic/LRUCache.java | 0
.../iceberg/flink/sink/dynamic/RowDataEvolver.java | 190 ---------------
.../flink/sink/dynamic/TableMetadataCache.java | 123 +++++-----
.../iceberg/flink/sink/dynamic/TableUpdater.java | 31 ++-
.../dynamic/TestDynamicTableUpdateOperator.java | 12 +-
.../iceberg/flink/sink/dynamic/TestLRUCache.java | 0
.../flink/sink/dynamic/TestRowDataConverter.java | 0
.../flink/sink/dynamic/TestRowDataEvolver.java | 256 ---------------------
.../flink/sink/dynamic/TestTableMetadataCache.java | 20 +-
.../flink/sink/dynamic/TestTableUpdater.java | 53 +++--
.../iceberg/flink/sink/dynamic/DataConverter.java | 0
.../flink/sink/dynamic/DynamicIcebergSink.java | 25 +-
.../flink/sink/dynamic/DynamicRecordProcessor.java | 41 ++--
.../sink/dynamic/DynamicTableUpdateOperator.java | 28 ++-
.../iceberg/flink/sink/dynamic/LRUCache.java | 0
.../iceberg/flink/sink/dynamic/RowDataEvolver.java | 190 ---------------
.../flink/sink/dynamic/TableMetadataCache.java | 123 +++++-----
.../iceberg/flink/sink/dynamic/TableUpdater.java | 31 ++-
.../dynamic/TestDynamicTableUpdateOperator.java | 12 +-
.../iceberg/flink/sink/dynamic/TestLRUCache.java | 0
.../flink/sink/dynamic/TestRowDataConverter.java | 0
.../flink/sink/dynamic/TestRowDataEvolver.java | 256 ---------------------
.../flink/sink/dynamic/TestTableMetadataCache.java | 20 +-
.../flink/sink/dynamic/TestTableUpdater.java | 53 +++--
28 files changed, 402 insertions(+), 1156 deletions(-)
copy flink/{v2.0 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/sink/dynamic/DataConverter.java
(100%)
copy flink/{v2.0 =>
v1.19}/flink/src/main/java/org/apache/iceberg/flink/sink/dynamic/LRUCache.java
(100%)
delete mode 100644
flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/sink/dynamic/RowDataEvolver.java
copy flink/{v2.0 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/sink/dynamic/TestLRUCache.java
(100%)
copy flink/{v2.0 =>
v1.19}/flink/src/test/java/org/apache/iceberg/flink/sink/dynamic/TestRowDataConverter.java
(100%)
delete mode 100644
flink/v1.19/flink/src/test/java/org/apache/iceberg/flink/sink/dynamic/TestRowDataEvolver.java
copy flink/{v2.0 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/sink/dynamic/DataConverter.java
(100%)
copy flink/{v2.0 =>
v1.20}/flink/src/main/java/org/apache/iceberg/flink/sink/dynamic/LRUCache.java
(100%)
delete mode 100644
flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/sink/dynamic/RowDataEvolver.java
copy flink/{v2.0 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/sink/dynamic/TestLRUCache.java
(100%)
copy flink/{v2.0 =>
v1.20}/flink/src/test/java/org/apache/iceberg/flink/sink/dynamic/TestRowDataConverter.java
(100%)
delete mode 100644
flink/v1.20/flink/src/test/java/org/apache/iceberg/flink/sink/dynamic/TestRowDataEvolver.java
