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 84be38acc5 Flink: Backport: Add test to ensure that append commits are
created in dynamic iceberg sink when possible (#15088)
add 8e255cd911 Flink: Backport: Dynamic Sink: Add case-insensitive field
matching (#15089)
No new revisions were added by this update.
Summary of changes:
.../flink/sink/dynamic/CompareSchemasVisitor.java | 47 ++++---
.../flink/sink/dynamic/DynamicIcebergSink.java | 20 ++-
.../flink/sink/dynamic/DynamicRecordProcessor.java | 20 ++-
.../sink/dynamic/DynamicTableUpdateOperator.java | 17 ++-
.../flink/sink/dynamic/EvolveSchemaVisitor.java | 24 +++-
.../flink/sink/dynamic/TableMetadataCache.java | 35 +++--
.../iceberg/flink/sink/dynamic/TableUpdater.java | 18 +--
.../sink/dynamic/TestCompareSchemasVisitor.java | 143 +++++++++++++++----
.../flink/sink/dynamic/TestDynamicIcebergSink.java | 85 ++++++++++++
.../dynamic/TestDynamicTableUpdateOperator.java | 82 +++++++++--
.../sink/dynamic/TestEvolveSchemaVisitor.java | 154 ++++++++++++++++++---
.../flink/sink/dynamic/TestTableMetadataCache.java | 104 +++++++++++---
.../flink/sink/dynamic/TestTableUpdater.java | 109 +++++++++++----
.../flink/sink/dynamic/CompareSchemasVisitor.java | 47 ++++---
.../flink/sink/dynamic/DynamicIcebergSink.java | 20 ++-
.../flink/sink/dynamic/DynamicRecordProcessor.java | 20 ++-
.../sink/dynamic/DynamicTableUpdateOperator.java | 17 ++-
.../flink/sink/dynamic/EvolveSchemaVisitor.java | 24 +++-
.../flink/sink/dynamic/TableMetadataCache.java | 35 +++--
.../iceberg/flink/sink/dynamic/TableUpdater.java | 18 +--
.../sink/dynamic/TestCompareSchemasVisitor.java | 143 +++++++++++++++----
.../flink/sink/dynamic/TestDynamicIcebergSink.java | 85 ++++++++++++
.../dynamic/TestDynamicTableUpdateOperator.java | 82 +++++++++--
.../sink/dynamic/TestEvolveSchemaVisitor.java | 154 ++++++++++++++++++---
.../flink/sink/dynamic/TestTableMetadataCache.java | 104 +++++++++++---
.../flink/sink/dynamic/TestTableUpdater.java | 109 +++++++++++----
26 files changed, 1396 insertions(+), 320 deletions(-)
