This is an automated email from the ASF dual-hosted git repository.
stevenwu pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/iceberg.git
from 30e761ebe4 Kafka Connect: Runtime distribution with integration tests
(#10739)
add e0a464f1cf Flink: improve snapshot compatibility check by comparing
projected sort schema in SortKeySerializer. also add unit tests for serializer
snapshot. (#10794)
No new revisions were added by this update.
Summary of changes:
.../flink/sink/shuffle/SortKeySerializer.java | 23 ++-
.../shuffle/TestSortKeySerializerSnapshot.java | 213 +++++++++++++++++++++
.../flink/sink/shuffle/SortKeySerializer.java | 23 ++-
.../shuffle/TestSortKeySerializerSnapshot.java | 213 +++++++++++++++++++++
.../flink/sink/shuffle/SortKeySerializer.java | 31 +--
.../shuffle/TestSortKeySerializerSnapshot.java | 213 +++++++++++++++++++++
6 files changed, 696 insertions(+), 20 deletions(-)
create mode 100644
flink/v1.17/flink/src/test/java/org/apache/iceberg/flink/sink/shuffle/TestSortKeySerializerSnapshot.java
create mode 100644
flink/v1.18/flink/src/test/java/org/apache/iceberg/flink/sink/shuffle/TestSortKeySerializerSnapshot.java
create mode 100644
flink/v1.19/flink/src/test/java/org/apache/iceberg/flink/sink/shuffle/TestSortKeySerializerSnapshot.java
