You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by xt...@apache.org on 2021/08/04 02:29:41 UTC
[flink] branch master updated (4d19a9f -> 4743666)
This is an automated email from the ASF dual-hosted git repository.
xtsong pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 4d19a9f [FLINK-23562][CI] Update CI JDK to 1.8.0_292
new 77b9a00 [hotfix][state][test] Add test file generation guide in AbstractOperatorRestoreTestBase
new 4743666 [FLINK-23529][core][test] Add Flink 1.13 MigrationVersion
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../kafka/FlinkKafkaConsumerBaseMigrationTest.java | 3 ++-
.../kafka/FlinkKafkaProducerMigrationTest.java | 3 ++-
.../serializer-snapshot | Bin
.../test-data | Bin
...nsumer-migration-test-flink1.13-empty-state-snapshot | Bin 0 -> 1465 bytes
.../kafka-consumer-migration-test-flink1.13-snapshot | Bin 0 -> 1519 bytes
.../kafka-migration-kafka-producer-flink-1.13-snapshot | Bin 0 -> 1240 bytes
.../serializer-snapshot | Bin
.../test-data | Bin
.../kinesis/FlinkKinesisConsumerMigrationTest.java | 3 ++-
...sis-consumer-migration-test-flink1.13-empty-snapshot | Bin 0 -> 2870 bytes
.../kinesis-consumer-migration-test-flink1.13-snapshot | Bin 0 -> 2938 bytes
.../serializer-snapshot | Bin
.../test-data | Bin
.../common/typeutils/TypeSerializerUpgradeTestBase.java | 2 +-
.../flink/testutils/migration/MigrationVersion.java | 3 ++-
.../serializer-snapshot | Bin
.../test-data | Bin
.../serializer-snapshot | Bin
.../test-data | Bin
.../serializer-snapshot | Bin
.../test-data | Bin
.../serializer-snapshot | Bin
.../test-data | 0
.../serializer-snapshot | Bin
.../test-data | 0
.../serializer-snapshot | Bin
.../test-data | Bin
.../serializer-snapshot | Bin
.../test-data | 0
.../serializer-snapshot | Bin
.../test-data | 0
.../serializer-snapshot | Bin
.../test-data | Bin
.../serializer-snapshot | Bin
.../test-data | 0
.../serializer-snapshot | Bin
.../test-data | Bin
.../serializer-snapshot | Bin
.../test-data | Bin
.../serializer-snapshot | Bin
.../test-data | Bin
.../serializer-snapshot | Bin
.../test-data | Bin
.../serializer-snapshot | Bin
.../test-data | 0
.../serializer-snapshot | Bin
.../test-data | 0
.../serializer-snapshot | Bin
.../test-data | 0
.../serializer-snapshot | Bin
.../test-data | Bin
.../serializer-snapshot | Bin
.../test-data | Bin
.../serializer-snapshot | Bin
.../test-data | Bin
.../serializer-snapshot | Bin
.../test-data | 0
.../serializer-snapshot | Bin
.../test-data | 0
.../serializer-snapshot | Bin
.../test-data | Bin
.../serializer-snapshot | Bin
.../test-data | Bin
.../serializer-snapshot | Bin
.../test-data | Bin
.../serializer-snapshot | Bin
.../test-data | Bin
.../serializer-snapshot | Bin
.../test-data | 0
.../serializer-snapshot | Bin
.../test-data | 0
.../serializer-snapshot | Bin
.../test-data | Bin
.../serializer-snapshot | Bin
.../test-data | Bin
.../serializer-snapshot | Bin
.../src/test/resources/list-serializer-1.13}/test-data | Bin
.../serializer-snapshot | Bin
.../test-data | Bin
.../serializer-snapshot | Bin
.../test-data | Bin
.../serializer-snapshot | Bin
.../test-data | Bin
.../serializer-snapshot | Bin
.../test-data | Bin
.../serializer-snapshot | Bin
.../test-data | 0
.../serializer-snapshot | Bin
.../test-data | 0
.../serializer-snapshot | Bin
.../test-data | Bin
.../serializer-snapshot | Bin
.../test-data | Bin
.../serializer-snapshot | Bin
.../test-data | Bin
.../serializer-snapshot | Bin
.../test-data | Bin
.../serializer-snapshot | Bin
.../test-data | Bin
.../serializer-snapshot | Bin
.../test-data | Bin
.../serializer-snapshot | Bin
.../test-data | Bin
.../serializer-snapshot | Bin
.../test-data | Bin
.../serializer-snapshot | Bin
.../test-data | Bin
.../serializer-snapshot | Bin
.../test-data | Bin
.../serializer-snapshot | Bin
.../test-data | Bin
.../serializer-snapshot | Bin
.../test-data | Bin
.../serializer-snapshot | Bin
.../test-data | Bin
.../serializer-snapshot | Bin
.../test-data | Bin
.../serializer-snapshot | Bin
.../test-data | Bin
.../serializer-snapshot | Bin
.../test-data | Bin
.../serializer-snapshot | Bin
.../test-data | Bin
.../serializer-snapshot | Bin
.../test-data | Bin
.../serializer-snapshot | Bin
.../test-data | Bin
.../serializer-snapshot | Bin
.../test-data | 0
.../serializer-snapshot | Bin
.../test-data | 0
.../serializer-snapshot | Bin
.../test-data | Bin
.../serializer-snapshot | Bin
.../test-data | Bin
.../serializer-snapshot | Bin
.../test-data | Bin
.../serializer-snapshot | Bin
.../test-data | Bin
.../ContinuousFileProcessingMigrationTest.java | 3 ++-
...tion-migration-test-1627550216000-flink1.13-snapshot | Bin 0 -> 324 bytes
.../resources/reader-migration-test-flink1.13-snapshot | Bin 0 -> 2622 bytes
.../org/apache/flink/cep/operator/CEPMigrationTest.java | 3 ++-
.../cep-migration-after-branching-flink1.13-snapshot | Bin 0 -> 5768 bytes
.../cep-migration-conditions-flink1.13-snapshot | Bin 0 -> 5415 bytes
...gration-single-pattern-afterwards-flink1.13-snapshot | Bin 0 -> 5165 bytes
...ep-migration-starting-new-pattern-flink1.13-snapshot | Bin 0 -> 5572 bytes
.../serializer-snapshot | Bin
.../test-data | Bin
.../serializer-snapshot | Bin
.../test-data | Bin
.../serializer-snapshot | Bin
.../test-data | Bin
.../serializer-snapshot | Bin
.../test-data | Bin
.../serializer-snapshot | Bin
.../test-data | Bin
.../serializer-snapshot | Bin
.../test-data | Bin
.../serializer-snapshot | Bin
.../test-data | Bin
.../serializer-snapshot | Bin
.../test-data | Bin
.../serializer-snapshot | Bin
.../test-data | Bin
.../serializer-snapshot | Bin
.../test-data | Bin
.../serializer-snapshot | Bin
.../test-data | Bin
.../serializer-snapshot | Bin
.../test-data | Bin
.../serializer-snapshot | Bin
.../test-data | Bin
.../serializer-snapshot | Bin
.../test-data | Bin
.../serializer-snapshot | Bin
.../test-data | Bin
.../serializer-snapshot | Bin
.../test-data | Bin
.../serializer-snapshot | Bin
.../test-data | Bin
.../serializer-snapshot | Bin
.../test-data | Bin
.../serializer-snapshot | Bin
.../test-data | Bin
.../serializer-snapshot | Bin
.../resources/void-namespace-serializer-1.13}/test-data | Bin
.../serializer-snapshot | Bin
.../test-data | Bin
.../serializer-snapshot | Bin
.../test-data | Bin
.../serializer-snapshot | Bin
.../test-data | Bin
.../serializer-snapshot | Bin
.../resources/scala-option-serializer-1.13}/test-data | Bin
.../serializer-snapshot | Bin
.../test/resources/scala-try-serializer-1.13/test-data | Bin 0 -> 3226 bytes
.../serializer-snapshot | Bin
.../test-data | Bin
.../serializer-snapshot | Bin
.../test-data | Bin
.../serializer-snapshot | Bin
.../test-data | Bin
.../serializer-snapshot | Bin
.../test-data | Bin
.../serializer-snapshot | Bin
.../test-data | Bin
.../serializer-snapshot | Bin
.../test-data | Bin
.../serializer-snapshot | Bin
.../test-data | Bin
.../serializer-snapshot | Bin
.../test-data | Bin
.../serializer-snapshot | Bin
.../test-data | Bin
.../windowing/WindowOperatorMigrationTest.java | 3 ++-
.../serializer-snapshot | Bin
.../test-data | Bin
.../serializer-snapshot | Bin
.../test-data | Bin
.../serializer-snapshot | Bin
.../test-data | Bin
.../serializer-snapshot | Bin
.../test-data | Bin
.../serializer-snapshot | Bin
.../test-data | Bin
.../serializer-snapshot | Bin
.../test-data | Bin
.../serializer-snapshot | Bin
.../test-data | 0
.../serializer-snapshot | Bin
.../test-data | Bin
...p-migration-test-apply-event-time-flink1.13-snapshot | Bin 0 -> 1761 bytes
...ration-test-apply-processing-time-flink1.13-snapshot | Bin 0 -> 1653 bytes
...igration-test-kryo-serialized-key-flink1.13-snapshot | Bin 0 -> 3983 bytes
...-migration-test-reduce-event-time-flink1.13-snapshot | Bin 0 -> 1617 bytes
...ation-test-reduce-processing-time-flink1.13-snapshot | Bin 0 -> 1558 bytes
...est-session-with-stateful-trigger-flink1.13-snapshot | Bin 0 -> 2669 bytes
...ession-with-stateful-trigger-mint-flink1.13-snapshot | Bin 0 -> 2163 bytes
.../list-view-serializer-1.13/serializer-snapshot | Bin 0 -> 269 bytes
.../test/resources/list-view-serializer-1.13/test-data | Bin 0 -> 16 bytes
.../map-view-serializer-1.13/serializer-snapshot | Bin 0 -> 351 bytes
.../test/resources/map-view-serializer-1.13/test-data | Bin 0 -> 11 bytes
.../utils/StatefulJobSavepointMigrationITCase.java | 4 +++-
.../StatefulJobWBroadcastStateMigrationITCase.java | 4 +++-
.../TypeSerializerSnapshotMigrationITCase.java | 4 +++-
.../restore/AbstractOperatorRestoreTestBase.java | 4 ++++
.../keyed/AbstractKeyedOperatorRestoreTestBase.java | 3 ++-
.../AbstractNonKeyedOperatorRestoreTestBase.java | 3 ++-
.../_metadata | Bin 0 -> 13838 bytes
.../_metadata | Bin 0 -> 13838 bytes
.../_metadata | Bin 0 -> 17257 bytes
.../_metadata | Bin 0 -> 17257 bytes
.../operatorstate/complexKeyed-flink1.13/_metadata | Bin 0 -> 13772 bytes
.../operatorstate/nonKeyed-flink1.13/_metadata | Bin 0 -> 3693 bytes
.../_metadata | Bin 0 -> 41962 bytes
.../_metadata | Bin 0 -> 41962 bytes
.../_metadata | Bin 0 -> 53733 bytes
.../_metadata | Bin 0 -> 53733 bytes
.../_metadata | Bin 0 -> 1266 bytes
.../_metadata | Bin 0 -> 1266 bytes
.../migration/StatefulJobSavepointMigrationITCase.scala | 4 +++-
.../StatefulJobWBroadcastStateMigrationITCase.scala | 4 +++-
264 files changed, 38 insertions(+), 15 deletions(-)
copy flink-connectors/flink-connector-kafka/src/test/resources/{context-state-serializer-1.12 => context-state-serializer-1.13}/serializer-snapshot (100%)
copy flink-connectors/flink-connector-kafka/src/test/resources/{context-state-serializer-1.12 => context-state-serializer-1.13}/test-data (100%)
create mode 100644 flink-connectors/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.13-empty-state-snapshot
create mode 100644 flink-connectors/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.13-snapshot
create mode 100644 flink-connectors/flink-connector-kafka/src/test/resources/kafka-migration-kafka-producer-flink-1.13-snapshot
copy flink-connectors/flink-connector-kafka/src/test/resources/{transaction-state-serializer-1.12 => transaction-state-serializer-1.13}/serializer-snapshot (100%)
copy flink-connectors/flink-connector-kafka/src/test/resources/{transaction-state-serializer-1.12 => transaction-state-serializer-1.13}/test-data (100%)
create mode 100644 flink-connectors/flink-connector-kinesis/src/test/resources/kinesis-consumer-migration-test-flink1.13-empty-snapshot
create mode 100644 flink-connectors/flink-connector-kinesis/src/test/resources/kinesis-consumer-migration-test-flink1.13-snapshot
copy flink-connectors/flink-hadoop-compatibility/src/test/resources/{writeable-serializer-1.12 => writeable-serializer-1.13}/serializer-snapshot (100%)
copy flink-connectors/flink-hadoop-compatibility/src/test/resources/{writeable-serializer-1.12 => writeable-serializer-1.13}/test-data (100%)
copy flink-core/src/test/resources/{big-dec-serializer-1.12 => big-dec-serializer-1.13}/serializer-snapshot (100%)
copy flink-core/src/test/resources/{big-dec-serializer-1.12 => big-dec-serializer-1.13}/test-data (100%)
copy flink-core/src/test/resources/{big-int-serializer-1.12 => big-int-serializer-1.13}/serializer-snapshot (100%)
copy flink-core/src/test/resources/{big-int-serializer-1.12 => big-int-serializer-1.13}/test-data (100%)
copy flink-core/src/test/resources/{boolean-primitive-array-serializer-1.12 => boolean-primitive-array-serializer-1.13}/serializer-snapshot (100%)
copy flink-core/src/test/resources/{boolean-primitive-array-serializer-1.12 => boolean-primitive-array-serializer-1.13}/test-data (100%)
copy flink-core/src/test/resources/{boolean-serializer-1.12 => boolean-serializer-1.13}/serializer-snapshot (100%)
copy flink-core/src/test/resources/{nullable-not-padded-serializer-1.12 => boolean-serializer-1.13}/test-data (100%)
copy flink-core/src/test/resources/{boolean-value-serializer-1.12 => boolean-value-serializer-1.13}/serializer-snapshot (100%)
copy flink-core/src/test/resources/{nullable-not-padded-serializer-1.12 => boolean-value-serializer-1.13}/test-data (100%)
copy flink-core/src/test/resources/{byte-primitive-array-serializer-1.12 => byte-primitive-array-serializer-1.13}/serializer-snapshot (100%)
copy flink-core/src/test/resources/{byte-primitive-array-serializer-1.12 => byte-primitive-array-serializer-1.13}/test-data (100%)
copy flink-core/src/test/resources/{byte-serializer-1.12 => byte-serializer-1.13}/serializer-snapshot (100%)
copy flink-core/src/test/resources/{byte-value-serializer-1.12 => byte-serializer-1.13}/test-data (100%)
copy flink-core/src/test/resources/{byte-value-serializer-1.12 => byte-value-serializer-1.13}/serializer-snapshot (100%)
copy flink-core/src/test/resources/{byte-value-serializer-1.12 => byte-value-serializer-1.13}/test-data (100%)
copy flink-core/src/test/resources/{char-primitive-array-serializer-1.12 => char-primitive-array-serializer-1.13}/serializer-snapshot (100%)
copy flink-core/src/test/resources/{short-primitive-array-serializer-1.12 => char-primitive-array-serializer-1.13}/test-data (100%)
copy flink-core/src/test/resources/{char-serializer-1.12 => char-serializer-1.13}/serializer-snapshot (100%)
copy flink-core/src/test/resources/{char-serializer-1.12 => char-serializer-1.13}/test-data (100%)
copy flink-core/src/test/resources/{char-value-serializer-1.12 => char-value-serializer-1.13}/serializer-snapshot (100%)
copy flink-core/src/test/resources/{char-value-serializer-1.12 => char-value-serializer-1.13}/test-data (100%)
copy flink-core/src/test/resources/{copyable-value-serializer-1.12 => copyable-value-serializer-1.13}/serializer-snapshot (100%)
copy flink-core/src/test/resources/{copyable-value-serializer-1.12 => copyable-value-serializer-1.13}/test-data (100%)
copy flink-core/src/test/resources/{date-serializer-1.12 => date-serializer-1.13}/serializer-snapshot (100%)
copy flink-core/src/test/resources/{sql-time-serializer-1.12 => date-serializer-1.13}/test-data (100%)
copy flink-core/src/test/resources/{double-primitive-array-serializer-1.12 => double-primitive-array-serializer-1.13}/serializer-snapshot (100%)
copy flink-core/src/test/resources/{double-primitive-array-serializer-1.12 => double-primitive-array-serializer-1.13}/test-data (100%)
copy flink-core/src/test/resources/{double-serializer-1.12 => double-serializer-1.13}/serializer-snapshot (100%)
copy flink-core/src/test/resources/{double-value-serializer-1.12 => double-serializer-1.13}/test-data (100%)
copy flink-core/src/test/resources/{double-value-serializer-1.12 => double-value-serializer-1.13}/serializer-snapshot (100%)
copy flink-core/src/test/resources/{double-value-serializer-1.12 => double-value-serializer-1.13}/test-data (100%)
copy flink-core/src/test/resources/{either-serializer-1.12 => either-serializer-1.13}/serializer-snapshot (100%)
copy flink-core/src/test/resources/{either-serializer-1.12 => either-serializer-1.13}/test-data (100%)
copy flink-core/src/test/resources/{enum-serializer-1.12 => enum-serializer-1.13}/serializer-snapshot (100%)
copy flink-core/src/test/resources/{enum-serializer-1.12 => enum-serializer-1.13}/test-data (100%)
copy flink-core/src/test/resources/{enum-serializerreconfig-1.12 => enum-serializerreconfig-1.13}/serializer-snapshot (100%)
copy flink-core/src/test/resources/{enum-serializerreconfig-1.12 => enum-serializerreconfig-1.13}/test-data (100%)
copy flink-core/src/test/resources/{float-primitive-array-serializer-1.12 => float-primitive-array-serializer-1.13}/serializer-snapshot (100%)
copy flink-core/src/test/resources/{float-primitive-array-serializer-1.12 => float-primitive-array-serializer-1.13}/test-data (100%)
copy flink-core/src/test/resources/{float-serializer-1.12 => float-serializer-1.13}/serializer-snapshot (100%)
copy flink-core/src/test/resources/{float-value-serializer-1.12 => float-serializer-1.13}/test-data (100%)
copy flink-core/src/test/resources/{float-value-serializer-1.12 => float-value-serializer-1.13}/serializer-snapshot (100%)
copy flink-core/src/test/resources/{float-value-serializer-1.12 => float-value-serializer-1.13}/test-data (100%)
copy flink-core/src/test/resources/{generic-array-serializer-1.12 => generic-array-serializer-1.13}/serializer-snapshot (100%)
copy flink-core/src/test/resources/{generic-array-serializer-1.12 => generic-array-serializer-1.13}/test-data (100%)
copy flink-core/src/test/resources/{int-primitive-array-serializer-1.12 => int-primitive-array-serializer-1.13}/serializer-snapshot (100%)
copy flink-core/src/test/resources/{int-primitive-array-serializer-1.12 => int-primitive-array-serializer-1.13}/test-data (100%)
copy flink-core/src/test/resources/{int-serializer-1.12 => int-serializer-1.13}/serializer-snapshot (100%)
copy flink-core/src/test/resources/{int-value-serializer-1.12 => int-serializer-1.13}/test-data (100%)
copy flink-core/src/test/resources/{int-value-serializer-1.12 => int-value-serializer-1.13}/serializer-snapshot (100%)
copy flink-core/src/test/resources/{int-value-serializer-1.12 => int-value-serializer-1.13}/test-data (100%)
copy flink-core/src/test/resources/{kryo-custom-type-serializer-changed-registration-order-1.12 => kryo-custom-type-serializer-changed-registration-order-1.13}/serializer-snapshot (100%)
copy flink-core/src/test/resources/{kryo-custom-type-serializer-changed-registration-order-1.12 => kryo-custom-type-serializer-changed-registration-order-1.13}/test-data (100%)
copy flink-core/src/test/resources/{kryo-type-serializer-changed-registration-order-1.12 => kryo-type-serializer-changed-registration-order-1.13}/serializer-snapshot (100%)
copy flink-core/src/test/resources/{kryo-type-serializer-changed-registration-order-1.12 => kryo-type-serializer-changed-registration-order-1.13}/test-data (100%)
copy flink-core/src/test/resources/{kryo-type-serializer-unrelated-config-after-restore-1.12 => kryo-type-serializer-empty-config-1.13}/serializer-snapshot (100%)
copy flink-core/src/test/resources/{kryo-type-serializer-unrelated-config-after-restore-1.12 => kryo-type-serializer-empty-config-1.13}/test-data (100%)
copy flink-core/src/test/resources/{kryo-type-serializer-unrelated-config-after-restore-1.12 => kryo-type-serializer-unrelated-config-after-restore-1.13}/serializer-snapshot (100%)
copy flink-core/src/test/resources/{kryo-type-serializer-unrelated-config-after-restore-1.12 => kryo-type-serializer-unrelated-config-after-restore-1.13}/test-data (100%)
copy flink-core/src/test/resources/{list-serializer-1.12 => list-serializer-1.13}/serializer-snapshot (100%)
copy {flink-runtime/src/test/resources/arraylist-serializer-1.12 => flink-core/src/test/resources/list-serializer-1.13}/test-data (100%)
copy flink-core/src/test/resources/{long-primitive-array-serializer-1.12 => long-primitive-array-serializer-1.13}/serializer-snapshot (100%)
copy flink-core/src/test/resources/{long-primitive-array-serializer-1.12 => long-primitive-array-serializer-1.13}/test-data (100%)
copy flink-core/src/test/resources/{long-serializer-1.12 => long-serializer-1.13}/serializer-snapshot (100%)
copy flink-core/src/test/resources/{long-value-serializer-1.12 => long-serializer-1.13}/test-data (100%)
copy flink-core/src/test/resources/{long-value-serializer-1.12 => long-value-serializer-1.13}/serializer-snapshot (100%)
copy flink-core/src/test/resources/{long-value-serializer-1.12 => long-value-serializer-1.13}/test-data (100%)
copy flink-core/src/test/resources/{map-serializer-1.12 => map-serializer-1.13}/serializer-snapshot (100%)
copy flink-core/src/test/resources/{map-serializer-1.12 => map-serializer-1.13}/test-data (100%)
copy flink-core/src/test/resources/{null-value-serializer-1.12 => null-value-serializer-1.13}/serializer-snapshot (100%)
copy flink-core/src/test/resources/{null-value-serializer-1.12 => null-value-serializer-1.13}/test-data (100%)
copy flink-core/src/test/resources/{nullable-not-padded-serializer-1.12 => nullable-not-padded-serializer-1.13}/serializer-snapshot (100%)
copy flink-core/src/test/resources/{nullable-not-padded-serializer-1.12 => nullable-not-padded-serializer-1.13}/test-data (100%)
copy flink-core/src/test/resources/{nullable-padded-serializer-1.12 => nullable-padded-serializer-1.13}/serializer-snapshot (100%)
copy flink-core/src/test/resources/{nullable-padded-serializer-1.12 => nullable-padded-serializer-1.13}/test-data (100%)
copy flink-core/src/test/resources/{pojo-serializer-identical-schema-1.9 => pojo-serializer-identical-schema-1.13}/serializer-snapshot (100%)
copy flink-core/src/test/resources/{pojo-serializer-identical-schema-1.9 => pojo-serializer-identical-schema-1.13}/test-data (100%)
copy flink-core/src/test/resources/{pojo-serializer-with-different-field-types-1.9 => pojo-serializer-with-different-field-types-1.13}/serializer-snapshot (100%)
copy flink-core/src/test/resources/{pojo-serializer-with-different-field-types-1.9 => pojo-serializer-with-different-field-types-1.13}/test-data (100%)
copy flink-core/src/test/resources/{pojo-serializer-with-different-field-types-in-registered-subclass-1.9 => pojo-serializer-with-different-field-types-in-registered-subclass-1.13}/serializer-snapshot (100%)
copy flink-core/src/test/resources/{pojo-serializer-with-different-field-types-in-registered-subclass-1.9 => pojo-serializer-with-different-field-types-in-registered-subclass-1.13}/test-data (100%)
copy flink-core/src/test/resources/{pojo-serializer-with-new-and-missing-registered-subclasses-1.9 => pojo-serializer-with-different-subclass-registration-order-1.13}/serializer-snapshot (100%)
copy flink-core/src/test/resources/{pojo-serializer-with-new-and-missing-registered-subclasses-1.9 => pojo-serializer-with-different-subclass-registration-order-1.13}/test-data (100%)
copy flink-core/src/test/resources/{pojo-serializer-with-new-and-missing-registered-subclasses-1.9 => pojo-serializer-with-missing-registered-subclass-1.13}/serializer-snapshot (100%)
copy flink-core/src/test/resources/{pojo-serializer-with-new-and-missing-registered-subclasses-1.9 => pojo-serializer-with-missing-registered-subclass-1.13}/test-data (100%)
copy flink-core/src/test/resources/{pojo-serializer-with-modified-schema-1.9 => pojo-serializer-with-modified-schema-1.13}/serializer-snapshot (100%)
copy flink-core/src/test/resources/{pojo-serializer-with-modified-schema-1.9 => pojo-serializer-with-modified-schema-1.13}/test-data (100%)
copy flink-core/src/test/resources/{pojo-serializer-with-modified-schema-in-registered-subclass-1.9 => pojo-serializer-with-modified-schema-in-registered-subclass-1.13}/serializer-snapshot (100%)
copy flink-core/src/test/resources/{pojo-serializer-with-modified-schema-in-registered-subclass-1.9 => pojo-serializer-with-modified-schema-in-registered-subclass-1.13}/test-data (100%)
copy flink-core/src/test/resources/{pojo-serializer-with-new-and-missing-registered-subclasses-1.9 => pojo-serializer-with-new-and-missing-registered-subclasses-1.13}/serializer-snapshot (100%)
copy flink-core/src/test/resources/{pojo-serializer-with-new-and-missing-registered-subclasses-1.9 => pojo-serializer-with-new-and-missing-registered-subclasses-1.13}/test-data (100%)
copy flink-core/src/test/resources/{pojo-serializer-with-non-registered-subclass-1.9 => pojo-serializer-with-new-registered-subclass-1.13}/serializer-snapshot (100%)
copy flink-core/src/test/resources/{pojo-serializer-with-non-registered-subclass-1.9 => pojo-serializer-with-new-registered-subclass-1.13}/test-data (100%)
copy flink-core/src/test/resources/{pojo-serializer-with-non-registered-subclass-1.9 => pojo-serializer-with-non-registered-subclass-1.13}/serializer-snapshot (100%)
copy flink-core/src/test/resources/{pojo-serializer-with-non-registered-subclass-1.9 => pojo-serializer-with-non-registered-subclass-1.13}/test-data (100%)
copy flink-core/src/test/resources/{row-serializer-1.12 => row-serializer-1.13}/serializer-snapshot (100%)
copy flink-core/src/test/resources/{row-serializer-1.12 => row-serializer-1.13}/test-data (100%)
copy flink-core/src/test/resources/{short-primitive-array-serializer-1.12 => short-primitive-array-serializer-1.13}/serializer-snapshot (100%)
copy flink-core/src/test/resources/{short-primitive-array-serializer-1.12 => short-primitive-array-serializer-1.13}/test-data (100%)
copy flink-core/src/test/resources/{short-serializer-1.12 => short-serializer-1.13}/serializer-snapshot (100%)
copy flink-core/src/test/resources/{short-value-serializer-1.12 => short-serializer-1.13}/test-data (100%)
copy flink-core/src/test/resources/{short-value-serializer-1.12 => short-value-serializer-1.13}/serializer-snapshot (100%)
copy flink-core/src/test/resources/{short-value-serializer-1.12 => short-value-serializer-1.13}/test-data (100%)
copy flink-core/src/test/resources/{sql-date-serializer-1.12 => sql-date-serializer-1.13}/serializer-snapshot (100%)
copy flink-core/src/test/resources/{sql-time-serializer-1.12 => sql-date-serializer-1.13}/test-data (100%)
copy flink-core/src/test/resources/{sql-time-serializer-1.12 => sql-time-serializer-1.13}/serializer-snapshot (100%)
copy flink-core/src/test/resources/{sql-time-serializer-1.12 => sql-time-serializer-1.13}/test-data (100%)
copy flink-core/src/test/resources/{sql-timestamp-serializer-1.12 => sql-timestamp-serializer-1.13}/serializer-snapshot (100%)
copy flink-core/src/test/resources/{sql-timestamp-serializer-1.12 => sql-timestamp-serializer-1.13}/test-data (100%)
copy flink-core/src/test/resources/{string-array-serializer-1.12 => string-array-serializer-1.13}/serializer-snapshot (100%)
copy flink-core/src/test/resources/{string-array-serializer-1.12 => string-array-serializer-1.13}/test-data (100%)
copy flink-core/src/test/resources/{string-serializer-1.12 => string-serializer-1.13}/serializer-snapshot (100%)
copy flink-core/src/test/resources/{string-serializer-1.12 => string-serializer-1.13}/test-data (100%)
copy flink-core/src/test/resources/{string-value-serializer-1.12 => string-value-serializer-1.13}/serializer-snapshot (100%)
copy flink-core/src/test/resources/{string-value-serializer-1.12 => string-value-serializer-1.13}/test-data (100%)
copy flink-core/src/test/resources/{tuple-serializer-1.12 => tuple-serializer-1.13}/serializer-snapshot (100%)
copy flink-core/src/test/resources/{tuple-serializer-1.12 => tuple-serializer-1.13}/test-data (100%)
copy flink-core/src/test/resources/{value-serializer-1.12 => value-serializer-1.13}/serializer-snapshot (100%)
copy flink-core/src/test/resources/{value-serializer-1.12 => value-serializer-1.13}/test-data (100%)
copy flink-formats/flink-avro/src/test/resources/{generic-avro-serializer-1.12 => generic-avro-serializer-1.13}/serializer-snapshot (100%)
copy flink-formats/flink-avro/src/test/resources/{specific-avro-serializer-1.12 => generic-avro-serializer-1.13}/test-data (100%)
copy flink-formats/flink-avro/src/test/resources/{specific-avro-serializer-1.12 => specific-avro-serializer-1.13}/serializer-snapshot (100%)
copy flink-formats/flink-avro/src/test/resources/{specific-avro-serializer-1.12 => specific-avro-serializer-1.13}/test-data (100%)
create mode 100644 flink-fs-tests/src/test/resources/monitoring-function-migration-test-1627550216000-flink1.13-snapshot
create mode 100644 flink-fs-tests/src/test/resources/reader-migration-test-flink1.13-snapshot
create mode 100644 flink-libraries/flink-cep/src/test/resources/cep-migration-after-branching-flink1.13-snapshot
create mode 100644 flink-libraries/flink-cep/src/test/resources/cep-migration-conditions-flink1.13-snapshot
create mode 100644 flink-libraries/flink-cep/src/test/resources/cep-migration-single-pattern-afterwards-flink1.13-snapshot
create mode 100644 flink-libraries/flink-cep/src/test/resources/cep-migration-starting-new-pattern-flink1.13-snapshot
copy flink-libraries/flink-cep/src/test/resources/{dewey-number-serializer-1.12 => dewey-number-serializer-1.13}/serializer-snapshot (100%)
copy flink-libraries/flink-cep/src/test/resources/{dewey-number-serializer-1.12 => dewey-number-serializer-1.13}/test-data (100%)
copy flink-libraries/flink-cep/src/test/resources/{event-id-serializer-1.12 => event-id-serializer-1.13}/serializer-snapshot (100%)
copy flink-libraries/flink-cep/src/test/resources/{event-id-serializer-1.12 => event-id-serializer-1.13}/test-data (100%)
copy flink-libraries/flink-cep/src/test/resources/{lockable-type-serializer-1.12 => lockable-type-serializer-1.13}/serializer-snapshot (100%)
copy flink-libraries/flink-cep/src/test/resources/{lockable-type-serializer-1.12 => lockable-type-serializer-1.13}/test-data (100%)
copy flink-libraries/flink-cep/src/test/resources/{nfa-state-serializer-1.12 => nfa-state-serializer-1.13}/serializer-snapshot (100%)
copy flink-libraries/flink-cep/src/test/resources/{nfa-state-serializer-1.12 => nfa-state-serializer-1.13}/test-data (100%)
copy flink-libraries/flink-cep/src/test/resources/{node-id-serializer-1.12 => node-id-serializer-1.13}/serializer-snapshot (100%)
copy flink-libraries/flink-cep/src/test/resources/{node-id-serializer-1.12 => node-id-serializer-1.13}/test-data (100%)
copy flink-libraries/flink-cep/src/test/resources/{shared-buffer-edge-serializer-1.12 => shared-buffer-edge-serializer-1.13}/serializer-snapshot (100%)
copy flink-libraries/flink-cep/src/test/resources/{shared-buffer-edge-serializer-1.12 => shared-buffer-edge-serializer-1.13}/test-data (100%)
copy flink-libraries/flink-gelly-examples/src/test/resources/{long-value-with-proper-hash-code-serializer-1.12 => long-value-with-proper-hash-code-serializer-1.13}/serializer-snapshot (100%)
copy flink-libraries/flink-gelly-examples/src/test/resources/{long-value-with-proper-hash-code-serializer-1.12 => long-value-with-proper-hash-code-serializer-1.13}/test-data (100%)
copy flink-libraries/flink-gelly/src/test/resources/{byte-value-array-serializer-1.12 => byte-value-array-serializer-1.13}/serializer-snapshot (100%)
copy flink-libraries/flink-gelly/src/test/resources/{byte-value-array-serializer-1.12 => byte-value-array-serializer-1.13}/test-data (100%)
copy flink-libraries/flink-gelly/src/test/resources/{char-value-array-serializer-1.12 => char-value-array-serializer-1.13}/serializer-snapshot (100%)
copy flink-libraries/flink-gelly/src/test/resources/{char-value-array-serializer-1.12 => char-value-array-serializer-1.13}/test-data (100%)
copy flink-libraries/flink-gelly/src/test/resources/{double-value-array-serializer-1.12 => double-value-array-serializer-1.13}/serializer-snapshot (100%)
copy flink-libraries/flink-gelly/src/test/resources/{double-value-array-serializer-1.12 => double-value-array-serializer-1.13}/test-data (100%)
copy flink-libraries/flink-gelly/src/test/resources/{float-value-array-serializer-1.12 => float-value-array-serializer-1.13}/serializer-snapshot (100%)
copy flink-libraries/flink-gelly/src/test/resources/{float-value-array-serializer-1.12 => float-value-array-serializer-1.13}/test-data (100%)
copy flink-libraries/flink-gelly/src/test/resources/{int-value-array-serializer-1.12 => int-value-array-serializer-1.13}/serializer-snapshot (100%)
copy flink-libraries/flink-gelly/src/test/resources/{int-value-array-serializer-1.12 => int-value-array-serializer-1.13}/test-data (100%)
copy flink-libraries/flink-gelly/src/test/resources/{long-value-array-serializer-1.12 => long-value-array-serializer-1.13}/serializer-snapshot (100%)
copy flink-libraries/flink-gelly/src/test/resources/{long-value-array-serializer-1.12 => long-value-array-serializer-1.13}/test-data (100%)
copy flink-libraries/flink-gelly/src/test/resources/{null-value-array-serializer-1.12 => null-value-array-serializer-1.13}/serializer-snapshot (100%)
copy flink-libraries/flink-gelly/src/test/resources/{null-value-array-serializer-1.12 => null-value-array-serializer-1.13}/test-data (100%)
copy flink-libraries/flink-gelly/src/test/resources/{short-value-array-serializer-1.12 => short-value-array-serializer-1.13}/serializer-snapshot (100%)
copy flink-libraries/flink-gelly/src/test/resources/{short-value-array-serializer-1.12 => short-value-array-serializer-1.13}/test-data (100%)
copy flink-libraries/flink-gelly/src/test/resources/{string-value-array-serializer-1.12 => string-value-array-serializer-1.13}/serializer-snapshot (100%)
copy flink-libraries/flink-gelly/src/test/resources/{string-value-array-serializer-1.12 => string-value-array-serializer-1.13}/test-data (100%)
copy flink-runtime/src/test/resources/{arraylist-serializer-1.12 => arraylist-serializer-1.13}/serializer-snapshot (100%)
copy flink-runtime/src/test/resources/{arraylist-serializer-1.12 => arraylist-serializer-1.13}/test-data (100%)
copy flink-runtime/src/test/resources/{java-serializer-1.12 => java-serializer-1.13}/serializer-snapshot (100%)
copy flink-runtime/src/test/resources/{java-serializer-1.12 => java-serializer-1.13}/test-data (100%)
copy flink-runtime/src/test/resources/{ttl-serializer-1.12 => ttl-serializer-1.13}/serializer-snapshot (100%)
copy flink-runtime/src/test/resources/{ttl-serializer-1.12 => ttl-serializer-1.13}/test-data (100%)
copy flink-runtime/src/test/resources/{void-namespace-serializer-1.12 => void-namespace-serializer-1.13}/serializer-snapshot (100%)
copy {flink-streaming-java/src/test/resources/global-window-serializer-1.12 => flink-runtime/src/test/resources/void-namespace-serializer-1.13}/test-data (100%)
copy flink-scala/src/test/resources/{scala-case-class-serializer-1.12 => scala-case-class-serializer-1.13}/serializer-snapshot (100%)
copy flink-scala/src/test/resources/{scala-case-class-serializer-1.12 => scala-case-class-serializer-1.13}/test-data (100%)
copy flink-scala/src/test/resources/{scala-either-serializer-1.12 => scala-either-serializer-1.13}/serializer-snapshot (100%)
copy flink-scala/src/test/resources/{scala-either-serializer-1.12 => scala-either-serializer-1.13}/test-data (100%)
copy flink-scala/src/test/resources/{scala-enum-serializer-1.12 => scala-enum-serializer-1.13}/serializer-snapshot (100%)
copy flink-scala/src/test/resources/{scala-enum-serializer-1.12 => scala-enum-serializer-1.13}/test-data (100%)
copy flink-scala/src/test/resources/{scala-option-serializer-1.12 => scala-option-serializer-1.13}/serializer-snapshot (100%)
copy {flink-streaming-java/src/test/resources/global-window-serializer-1.12 => flink-scala/src/test/resources/scala-option-serializer-1.13}/test-data (100%)
copy flink-scala/src/test/resources/{scala-try-serializer-1.12 => scala-try-serializer-1.13}/serializer-snapshot (100%)
create mode 100644 flink-scala/src/test/resources/scala-try-serializer-1.13/test-data
copy flink-scala/src/test/resources/{traversable-serializer-bitset-1.12 => traversable-serializer-bitset-1.13}/serializer-snapshot (100%)
copy flink-scala/src/test/resources/{traversable-serializer-bitset-1.12 => traversable-serializer-bitset-1.13}/test-data (100%)
copy flink-scala/src/test/resources/{traversable-serializer-indexedseq-1.12 => traversable-serializer-indexedseq-1.13}/serializer-snapshot (100%)
copy flink-scala/src/test/resources/{traversable-serializer-seq-1.12 => traversable-serializer-indexedseq-1.13}/test-data (100%)
copy flink-scala/src/test/resources/{traversable-serializer-linearseq-1.12 => traversable-serializer-linearseq-1.13}/serializer-snapshot (100%)
copy flink-scala/src/test/resources/{traversable-serializer-set-1.12 => traversable-serializer-linearseq-1.13}/test-data (100%)
copy flink-scala/src/test/resources/{traversable-serializer-map-1.12 => traversable-serializer-map-1.13}/serializer-snapshot (100%)
copy flink-scala/src/test/resources/{traversable-serializer-map-1.12 => traversable-serializer-map-1.13}/test-data (100%)
copy flink-scala/src/test/resources/{traversable-serializer-mutable-list-1.12 => traversable-serializer-mutable-list-1.13}/serializer-snapshot (100%)
copy flink-scala/src/test/resources/{traversable-serializer-seq-1.12 => traversable-serializer-mutable-list-1.13}/test-data (100%)
copy flink-scala/src/test/resources/{traversable-serializer-seq-1.12 => traversable-serializer-seq-1.13}/serializer-snapshot (100%)
copy flink-scala/src/test/resources/{traversable-serializer-seq-1.12 => traversable-serializer-seq-1.13}/test-data (100%)
copy flink-scala/src/test/resources/{traversable-serializer-set-1.12 => traversable-serializer-set-1.13}/serializer-snapshot (100%)
copy flink-scala/src/test/resources/{traversable-serializer-set-1.12 => traversable-serializer-set-1.13}/test-data (100%)
copy flink-scala/src/test/resources/{traversable-serializer-with-case-class-1.12 => traversable-serializer-with-case-class-1.13}/serializer-snapshot (100%)
copy flink-scala/src/test/resources/{traversable-serializer-with-case-class-1.12 => traversable-serializer-with-case-class-1.13}/test-data (100%)
copy flink-scala/src/test/resources/{traversable-serializer-with-pojo-1.12 => traversable-serializer-with-pojo-1.13}/serializer-snapshot (100%)
copy flink-scala/src/test/resources/{traversable-serializer-with-pojo-1.12 => traversable-serializer-with-pojo-1.13}/test-data (100%)
copy flink-streaming-java/src/test/resources/{buffer-entry-serializer-1.12 => buffer-entry-serializer-1.13}/serializer-snapshot (100%)
copy flink-streaming-java/src/test/resources/{buffer-entry-serializer-1.12 => buffer-entry-serializer-1.13}/test-data (100%)
copy flink-streaming-java/src/test/resources/{global-window-serializer-1.12 => global-window-serializer-1.13}/serializer-snapshot (100%)
copy flink-streaming-java/src/test/resources/{global-window-serializer-1.12 => global-window-serializer-1.13}/test-data (100%)
copy flink-streaming-java/src/test/resources/{stream-element-serializer-1.12 => stream-element-serializer-1.13}/serializer-snapshot (100%)
copy flink-streaming-java/src/test/resources/{stream-element-serializer-1.12 => stream-element-serializer-1.13}/test-data (100%)
copy flink-streaming-java/src/test/resources/{time-window-serializer-1.12 => time-window-serializer-1.13}/serializer-snapshot (100%)
copy flink-streaming-java/src/test/resources/{time-window-serializer-1.12 => time-window-serializer-1.13}/test-data (100%)
copy flink-streaming-java/src/test/resources/{timer-serializer-1.12 => timer-serializer-1.13}/serializer-snapshot (100%)
copy flink-streaming-java/src/test/resources/{timer-serializer-1.12 => timer-serializer-1.13}/test-data (100%)
copy flink-streaming-java/src/test/resources/{two-phase-commit-sink-state-serializer-1.12 => two-phase-commit-sink-state-serializer-1.13}/serializer-snapshot (100%)
copy flink-streaming-java/src/test/resources/{two-phase-commit-sink-state-serializer-1.12 => two-phase-commit-sink-state-serializer-1.13}/test-data (100%)
copy flink-streaming-java/src/test/resources/{union-serializer-two-1.12 => union-serializer-one-1.13}/serializer-snapshot (100%)
copy flink-streaming-java/src/test/resources/{union-serializer-one-1.12 => union-serializer-one-1.13}/test-data (100%)
copy flink-streaming-java/src/test/resources/{union-serializer-two-1.12 => union-serializer-two-1.13}/serializer-snapshot (100%)
copy flink-streaming-java/src/test/resources/{union-serializer-two-1.12 => union-serializer-two-1.13}/test-data (100%)
create mode 100644 flink-streaming-java/src/test/resources/win-op-migration-test-apply-event-time-flink1.13-snapshot
create mode 100644 flink-streaming-java/src/test/resources/win-op-migration-test-apply-processing-time-flink1.13-snapshot
create mode 100644 flink-streaming-java/src/test/resources/win-op-migration-test-kryo-serialized-key-flink1.13-snapshot
create mode 100644 flink-streaming-java/src/test/resources/win-op-migration-test-reduce-event-time-flink1.13-snapshot
create mode 100644 flink-streaming-java/src/test/resources/win-op-migration-test-reduce-processing-time-flink1.13-snapshot
create mode 100644 flink-streaming-java/src/test/resources/win-op-migration-test-session-with-stateful-trigger-flink1.13-snapshot
create mode 100644 flink-streaming-java/src/test/resources/win-op-migration-test-session-with-stateful-trigger-mint-flink1.13-snapshot
create mode 100644 flink-table/flink-table-planner/src/test/resources/list-view-serializer-1.13/serializer-snapshot
create mode 100644 flink-table/flink-table-planner/src/test/resources/list-view-serializer-1.13/test-data
create mode 100644 flink-table/flink-table-planner/src/test/resources/map-view-serializer-1.13/serializer-snapshot
create mode 100644 flink-table/flink-table-planner/src/test/resources/map-view-serializer-1.13/test-data
create mode 100644 flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.13-rocksdb-savepoint/_metadata
create mode 100644 flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.13-savepoint/_metadata
create mode 100644 flink-tests/src/test/resources/new-stateful-udf-migration-itcase-flink1.13-rocksdb-savepoint/_metadata
create mode 100644 flink-tests/src/test/resources/new-stateful-udf-migration-itcase-flink1.13-savepoint/_metadata
create mode 100644 flink-tests/src/test/resources/operatorstate/complexKeyed-flink1.13/_metadata
create mode 100644 flink-tests/src/test/resources/operatorstate/nonKeyed-flink1.13/_metadata
create mode 100644 flink-tests/src/test/resources/stateful-scala-udf-migration-itcase-flink1.13-jobmanager-savepoint/_metadata
create mode 100644 flink-tests/src/test/resources/stateful-scala-udf-migration-itcase-flink1.13-rocksdb-savepoint/_metadata
create mode 100644 flink-tests/src/test/resources/stateful-scala-with-broadcast-udf-migration-itcase-flink1.13-jobmanager-savepoint/_metadata
create mode 100644 flink-tests/src/test/resources/stateful-scala-with-broadcast-udf-migration-itcase-flink1.13-rocksdb-savepoint/_metadata
create mode 100644 flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.13-rocksdb-savepoint/_metadata
create mode 100644 flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.13-savepoint/_metadata
[flink] 02/02: [FLINK-23529][core][test] Add Flink 1.13
MigrationVersion
Posted by xt...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
xtsong pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 474366618ce80520783f27c959232f11f8f9a7d0
Author: tsreaper <ts...@gmail.com>
AuthorDate: Tue Aug 3 10:20:42 2021 +0800
[FLINK-23529][core][test] Add Flink 1.13 MigrationVersion
This closes #16636
---
.../kafka/FlinkKafkaConsumerBaseMigrationTest.java | 3 ++-
.../kafka/FlinkKafkaProducerMigrationTest.java | 3 ++-
.../context-state-serializer-1.13/serializer-snapshot | Bin 0 -> 126 bytes
.../resources/context-state-serializer-1.13/test-data | Bin 0 -> 19 bytes
...nsumer-migration-test-flink1.13-empty-state-snapshot | Bin 0 -> 1465 bytes
.../kafka-consumer-migration-test-flink1.13-snapshot | Bin 0 -> 1519 bytes
.../kafka-migration-kafka-producer-flink-1.13-snapshot | Bin 0 -> 1240 bytes
.../serializer-snapshot | Bin 0 -> 134 bytes
.../transaction-state-serializer-1.13/test-data | Bin 0 -> 17 bytes
.../kinesis/FlinkKinesisConsumerMigrationTest.java | 3 ++-
...sis-consumer-migration-test-flink1.13-empty-snapshot | Bin 0 -> 2870 bytes
.../kinesis-consumer-migration-test-flink1.13-snapshot | Bin 0 -> 2938 bytes
.../writeable-serializer-1.13/serializer-snapshot | Bin 0 -> 187 bytes
.../test/resources/writeable-serializer-1.13/test-data | Bin 0 -> 7 bytes
.../common/typeutils/TypeSerializerUpgradeTestBase.java | 2 +-
.../flink/testutils/migration/MigrationVersion.java | 3 ++-
.../big-dec-serializer-1.13/serializer-snapshot | Bin 0 -> 94 bytes
.../test/resources/big-dec-serializer-1.13/test-data | Bin 0 -> 24 bytes
.../big-int-serializer-1.13/serializer-snapshot | Bin 0 -> 94 bytes
.../test/resources/big-int-serializer-1.13/test-data | Bin 0 -> 19 bytes
.../serializer-snapshot | Bin 0 -> 130 bytes
.../boolean-primitive-array-serializer-1.13/test-data | Bin 0 -> 6 bytes
.../boolean-serializer-1.13/serializer-snapshot | Bin 0 -> 96 bytes
.../test/resources/boolean-serializer-1.13/test-data | 1 +
.../boolean-value-serializer-1.13/serializer-snapshot | Bin 0 -> 106 bytes
.../resources/boolean-value-serializer-1.13/test-data | 1 +
.../serializer-snapshot | Bin 0 -> 124 bytes
.../byte-primitive-array-serializer-1.13/test-data | Bin 0 -> 14 bytes
.../resources/byte-serializer-1.13/serializer-snapshot | Bin 0 -> 90 bytes
.../src/test/resources/byte-serializer-1.13/test-data | 1 +
.../byte-value-serializer-1.13/serializer-snapshot | Bin 0 -> 100 bytes
.../test/resources/byte-value-serializer-1.13/test-data | 1 +
.../serializer-snapshot | Bin 0 -> 124 bytes
.../char-primitive-array-serializer-1.13/test-data | Bin 0 -> 24 bytes
.../resources/char-serializer-1.13/serializer-snapshot | Bin 0 -> 90 bytes
.../src/test/resources/char-serializer-1.13/test-data | 1 +
.../char-value-serializer-1.13/serializer-snapshot | Bin 0 -> 100 bytes
.../test/resources/char-value-serializer-1.13/test-data | Bin 0 -> 2 bytes
.../copyable-value-serializer-1.13/serializer-snapshot | Bin 0 -> 199 bytes
.../resources/copyable-value-serializer-1.13/test-data | Bin 0 -> 8 bytes
.../resources/date-serializer-1.13/serializer-snapshot | Bin 0 -> 90 bytes
.../src/test/resources/date-serializer-1.13/test-data | Bin 0 -> 8 bytes
.../serializer-snapshot | Bin 0 -> 128 bytes
.../double-primitive-array-serializer-1.13/test-data | Bin 0 -> 84 bytes
.../double-serializer-1.13/serializer-snapshot | Bin 0 -> 94 bytes
.../src/test/resources/double-serializer-1.13/test-data | 1 +
.../double-value-serializer-1.13/serializer-snapshot | Bin 0 -> 104 bytes
.../resources/double-value-serializer-1.13/test-data | 1 +
.../either-serializer-1.13/serializer-snapshot | Bin 0 -> 276 bytes
.../src/test/resources/either-serializer-1.13/test-data | 1 +
.../resources/enum-serializer-1.13/serializer-snapshot | Bin 0 -> 188 bytes
.../src/test/resources/enum-serializer-1.13/test-data | Bin 0 -> 4 bytes
.../enum-serializerreconfig-1.13/serializer-snapshot | Bin 0 -> 163 bytes
.../resources/enum-serializerreconfig-1.13/test-data | Bin 0 -> 4 bytes
.../serializer-snapshot | Bin 0 -> 126 bytes
.../float-primitive-array-serializer-1.13/test-data | Bin 0 -> 44 bytes
.../resources/float-serializer-1.13/serializer-snapshot | Bin 0 -> 92 bytes
.../src/test/resources/float-serializer-1.13/test-data | 1 +
.../float-value-serializer-1.13/serializer-snapshot | Bin 0 -> 102 bytes
.../resources/float-value-serializer-1.13/test-data | 1 +
.../generic-array-serializer-1.13/serializer-snapshot | Bin 0 -> 211 bytes
.../resources/generic-array-serializer-1.13/test-data | Bin 0 -> 19 bytes
.../serializer-snapshot | Bin 0 -> 122 bytes
.../int-primitive-array-serializer-1.13/test-data | Bin 0 -> 44 bytes
.../resources/int-serializer-1.13/serializer-snapshot | Bin 0 -> 88 bytes
.../src/test/resources/int-serializer-1.13/test-data | Bin 0 -> 4 bytes
.../int-value-serializer-1.13/serializer-snapshot | Bin 0 -> 98 bytes
.../test/resources/int-value-serializer-1.13/test-data | Bin 0 -> 4 bytes
.../serializer-snapshot | Bin 0 -> 1718 bytes
.../test-data | 1 +
.../serializer-snapshot | Bin 0 -> 1525 bytes
.../test-data | 1 +
.../serializer-snapshot | Bin 0 -> 745 bytes
.../kryo-type-serializer-empty-config-1.13/test-data | Bin 0 -> 90 bytes
.../serializer-snapshot | Bin 0 -> 745 bytes
.../test-data | Bin 0 -> 90 bytes
.../resources/list-serializer-1.13/serializer-snapshot | Bin 0 -> 185 bytes
.../src/test/resources/list-serializer-1.13/test-data | Bin 0 -> 17 bytes
.../serializer-snapshot | Bin 0 -> 124 bytes
.../long-primitive-array-serializer-1.13/test-data | Bin 0 -> 84 bytes
.../resources/long-serializer-1.13/serializer-snapshot | Bin 0 -> 90 bytes
.../src/test/resources/long-serializer-1.13/test-data | Bin 0 -> 8 bytes
.../long-value-serializer-1.13/serializer-snapshot | Bin 0 -> 100 bytes
.../test/resources/long-value-serializer-1.13/test-data | Bin 0 -> 8 bytes
.../resources/map-serializer-1.13/serializer-snapshot | Bin 0 -> 268 bytes
.../src/test/resources/map-serializer-1.13/test-data | Bin 0 -> 25 bytes
.../null-value-serializer-1.13/serializer-snapshot | Bin 0 -> 100 bytes
.../test/resources/null-value-serializer-1.13/test-data | 0
.../serializer-snapshot | Bin 0 -> 209 bytes
.../nullable-not-padded-serializer-1.13/test-data | 1 +
.../nullable-padded-serializer-1.13/serializer-snapshot | Bin 0 -> 209 bytes
.../resources/nullable-padded-serializer-1.13/test-data | Bin 0 -> 9 bytes
.../serializer-snapshot | Bin 0 -> 1214 bytes
.../pojo-serializer-identical-schema-1.13/test-data | Bin 0 -> 21 bytes
.../serializer-snapshot | Bin 0 -> 294 bytes
.../test-data | Bin 0 -> 6 bytes
.../serializer-snapshot | Bin 0 -> 2570 bytes
.../test-data | Bin 0 -> 24 bytes
.../serializer-snapshot | Bin 0 -> 4372 bytes
.../test-data | Bin 0 -> 21 bytes
.../serializer-snapshot | Bin 0 -> 4372 bytes
.../test-data | Bin 0 -> 21 bytes
.../serializer-snapshot | Bin 0 -> 686 bytes
.../pojo-serializer-with-modified-schema-1.13/test-data | Bin 0 -> 28 bytes
.../serializer-snapshot | Bin 0 -> 1082 bytes
.../test-data | Bin 0 -> 27 bytes
.../serializer-snapshot | Bin 0 -> 4372 bytes
.../test-data | Bin 0 -> 21 bytes
.../serializer-snapshot | Bin 0 -> 2789 bytes
.../test-data | Bin 0 -> 134 bytes
.../serializer-snapshot | Bin 0 -> 2789 bytes
.../test-data | Bin 0 -> 134 bytes
.../resources/row-serializer-1.13/serializer-snapshot | Bin 0 -> 465 bytes
.../src/test/resources/row-serializer-1.13/test-data | Bin 0 -> 20 bytes
.../serializer-snapshot | Bin 0 -> 126 bytes
.../short-primitive-array-serializer-1.13/test-data | Bin 0 -> 24 bytes
.../resources/short-serializer-1.13/serializer-snapshot | Bin 0 -> 92 bytes
.../src/test/resources/short-serializer-1.13/test-data | Bin 0 -> 2 bytes
.../short-value-serializer-1.13/serializer-snapshot | Bin 0 -> 102 bytes
.../resources/short-value-serializer-1.13/test-data | Bin 0 -> 2 bytes
.../sql-date-serializer-1.13/serializer-snapshot | Bin 0 -> 96 bytes
.../test/resources/sql-date-serializer-1.13/test-data | Bin 0 -> 8 bytes
.../sql-time-serializer-1.13/serializer-snapshot | Bin 0 -> 96 bytes
.../test/resources/sql-time-serializer-1.13/test-data | Bin 0 -> 8 bytes
.../sql-timestamp-serializer-1.13/serializer-snapshot | Bin 0 -> 106 bytes
.../resources/sql-timestamp-serializer-1.13/test-data | Bin 0 -> 12 bytes
.../string-array-serializer-1.13/serializer-snapshot | Bin 0 -> 110 bytes
.../resources/string-array-serializer-1.13/test-data | Bin 0 -> 24 bytes
.../string-serializer-1.13/serializer-snapshot | Bin 0 -> 94 bytes
.../src/test/resources/string-serializer-1.13/test-data | 1 +
.../string-value-serializer-1.13/serializer-snapshot | Bin 0 -> 104 bytes
.../resources/string-value-serializer-1.13/test-data | 1 +
.../resources/tuple-serializer-1.13/serializer-snapshot | Bin 0 -> 401 bytes
.../src/test/resources/tuple-serializer-1.13/test-data | Bin 0 -> 22 bytes
.../resources/value-serializer-1.13/serializer-snapshot | Bin 0 -> 175 bytes
.../src/test/resources/value-serializer-1.13/test-data | Bin 0 -> 9 bytes
.../generic-avro-serializer-1.13/serializer-snapshot | Bin 0 -> 369 bytes
.../resources/generic-avro-serializer-1.13/test-data | Bin 0 -> 51 bytes
.../specific-avro-serializer-1.13/serializer-snapshot | Bin 0 -> 379 bytes
.../resources/specific-avro-serializer-1.13/test-data | Bin 0 -> 51 bytes
.../ContinuousFileProcessingMigrationTest.java | 3 ++-
...tion-migration-test-1627550216000-flink1.13-snapshot | Bin 0 -> 324 bytes
.../resources/reader-migration-test-flink1.13-snapshot | Bin 0 -> 2622 bytes
.../org/apache/flink/cep/operator/CEPMigrationTest.java | 3 ++-
.../cep-migration-after-branching-flink1.13-snapshot | Bin 0 -> 5768 bytes
.../cep-migration-conditions-flink1.13-snapshot | Bin 0 -> 5415 bytes
...gration-single-pattern-afterwards-flink1.13-snapshot | Bin 0 -> 5165 bytes
...ep-migration-starting-new-pattern-flink1.13-snapshot | Bin 0 -> 5572 bytes
.../dewey-number-serializer-1.13/serializer-snapshot | Bin 0 -> 98 bytes
.../resources/dewey-number-serializer-1.13/test-data | Bin 0 -> 8 bytes
.../event-id-serializer-1.13/serializer-snapshot | Bin 0 -> 99 bytes
.../test/resources/event-id-serializer-1.13/test-data | Bin 0 -> 12 bytes
.../lockable-type-serializer-1.13/serializer-snapshot | Bin 0 -> 188 bytes
.../resources/lockable-type-serializer-1.13/test-data | Bin 0 -> 10 bytes
.../nfa-state-serializer-1.13/serializer-snapshot | Bin 0 -> 477 bytes
.../test/resources/nfa-state-serializer-1.13/test-data | Bin 0 -> 8 bytes
.../node-id-serializer-1.13/serializer-snapshot | Bin 0 -> 211 bytes
.../test/resources/node-id-serializer-1.13/test-data | Bin 0 -> 18 bytes
.../serializer-snapshot | Bin 0 -> 447 bytes
.../shared-buffer-edge-serializer-1.13/test-data | Bin 0 -> 26 bytes
.../serializer-snapshot | Bin 0 -> 162 bytes
.../test-data | Bin 0 -> 8 bytes
.../serializer-snapshot | Bin 0 -> 107 bytes
.../byte-value-array-serializer-1.13/test-data | Bin 0 -> 6 bytes
.../serializer-snapshot | Bin 0 -> 107 bytes
.../char-value-array-serializer-1.13/test-data | Bin 0 -> 10 bytes
.../serializer-snapshot | Bin 0 -> 111 bytes
.../double-value-array-serializer-1.13/test-data | Bin 0 -> 20 bytes
.../serializer-snapshot | Bin 0 -> 109 bytes
.../float-value-array-serializer-1.13/test-data | Bin 0 -> 12 bytes
.../int-value-array-serializer-1.13/serializer-snapshot | Bin 0 -> 105 bytes
.../resources/int-value-array-serializer-1.13/test-data | Bin 0 -> 12 bytes
.../serializer-snapshot | Bin 0 -> 107 bytes
.../long-value-array-serializer-1.13/test-data | Bin 0 -> 20 bytes
.../serializer-snapshot | Bin 0 -> 107 bytes
.../null-value-array-serializer-1.13/test-data | Bin 0 -> 4 bytes
.../serializer-snapshot | Bin 0 -> 109 bytes
.../short-value-array-serializer-1.13/test-data | Bin 0 -> 8 bytes
.../serializer-snapshot | Bin 0 -> 111 bytes
.../string-value-array-serializer-1.13/test-data | Bin 0 -> 16 bytes
.../arraylist-serializer-1.13/serializer-snapshot | Bin 0 -> 178 bytes
.../test/resources/arraylist-serializer-1.13/test-data | Bin 0 -> 17 bytes
.../resources/java-serializer-1.13/serializer-snapshot | Bin 0 -> 78 bytes
.../src/test/resources/java-serializer-1.13/test-data | Bin 0 -> 81 bytes
.../resources/ttl-serializer-1.13/serializer-snapshot | Bin 0 -> 278 bytes
.../src/test/resources/ttl-serializer-1.13/test-data | Bin 0 -> 21 bytes
.../void-namespace-serializer-1.13/serializer-snapshot | Bin 0 -> 96 bytes
.../resources/void-namespace-serializer-1.13/test-data | Bin 0 -> 1 bytes
.../serializer-snapshot | Bin 0 -> 323 bytes
.../scala-case-class-serializer-1.13/test-data | Bin 0 -> 10 bytes
.../scala-either-serializer-1.13/serializer-snapshot | Bin 0 -> 270 bytes
.../resources/scala-either-serializer-1.13/test-data | Bin 0 -> 13 bytes
.../scala-enum-serializer-1.13/serializer-snapshot | Bin 0 -> 146 bytes
.../test/resources/scala-enum-serializer-1.13/test-data | Bin 0 -> 4 bytes
.../scala-option-serializer-1.13/serializer-snapshot | Bin 0 -> 186 bytes
.../resources/scala-option-serializer-1.13/test-data | Bin 0 -> 1 bytes
.../scala-try-serializer-1.13/serializer-snapshot | Bin 0 -> 672 bytes
.../test/resources/scala-try-serializer-1.13/test-data | Bin 0 -> 3226 bytes
.../serializer-snapshot | Bin 0 -> 286 bytes
.../traversable-serializer-bitset-1.13/test-data | Bin 0 -> 19 bytes
.../serializer-snapshot | Bin 0 -> 270 bytes
.../traversable-serializer-indexedseq-1.13/test-data | Bin 0 -> 19 bytes
.../serializer-snapshot | Bin 0 -> 302 bytes
.../traversable-serializer-linearseq-1.13/test-data | Bin 0 -> 19 bytes
.../traversable-serializer-map-1.13/serializer-snapshot | Bin 0 -> 479 bytes
.../resources/traversable-serializer-map-1.13/test-data | Bin 0 -> 27 bytes
.../serializer-snapshot | Bin 0 -> 322 bytes
.../traversable-serializer-mutable-list-1.13/test-data | Bin 0 -> 19 bytes
.../traversable-serializer-seq-1.13/serializer-snapshot | Bin 0 -> 256 bytes
.../resources/traversable-serializer-seq-1.13/test-data | Bin 0 -> 19 bytes
.../traversable-serializer-set-1.13/serializer-snapshot | Bin 0 -> 256 bytes
.../resources/traversable-serializer-set-1.13/test-data | Bin 0 -> 19 bytes
.../serializer-snapshot | Bin 0 -> 485 bytes
.../test-data | Bin 0 -> 27 bytes
.../serializer-snapshot | Bin 0 -> 977 bytes
.../traversable-serializer-with-pojo-1.13/test-data | Bin 0 -> 33 bytes
.../windowing/WindowOperatorMigrationTest.java | 3 ++-
.../buffer-entry-serializer-1.13/serializer-snapshot | Bin 0 -> 214 bytes
.../resources/buffer-entry-serializer-1.13/test-data | Bin 0 -> 7 bytes
.../global-window-serializer-1.13/serializer-snapshot | Bin 0 -> 113 bytes
.../resources/global-window-serializer-1.13/test-data | Bin 0 -> 1 bytes
.../stream-element-serializer-1.13/serializer-snapshot | Bin 0 -> 223 bytes
.../resources/stream-element-serializer-1.13/test-data | Bin 0 -> 13 bytes
.../time-window-serializer-1.13/serializer-snapshot | Bin 0 -> 109 bytes
.../resources/time-window-serializer-1.13/test-data | Bin 0 -> 16 bytes
.../resources/timer-serializer-1.13/serializer-snapshot | Bin 0 -> 268 bytes
.../src/test/resources/timer-serializer-1.13/test-data | Bin 0 -> 16 bytes
.../serializer-snapshot | Bin 0 -> 300 bytes
.../test-data | Bin 0 -> 35 bytes
.../union-serializer-one-1.13/serializer-snapshot | Bin 0 -> 288 bytes
.../test/resources/union-serializer-one-1.13/test-data | 1 +
.../union-serializer-two-1.13/serializer-snapshot | Bin 0 -> 288 bytes
.../test/resources/union-serializer-two-1.13/test-data | Bin 0 -> 9 bytes
...p-migration-test-apply-event-time-flink1.13-snapshot | Bin 0 -> 1761 bytes
...ration-test-apply-processing-time-flink1.13-snapshot | Bin 0 -> 1653 bytes
...igration-test-kryo-serialized-key-flink1.13-snapshot | Bin 0 -> 3983 bytes
...-migration-test-reduce-event-time-flink1.13-snapshot | Bin 0 -> 1617 bytes
...ation-test-reduce-processing-time-flink1.13-snapshot | Bin 0 -> 1558 bytes
...est-session-with-stateful-trigger-flink1.13-snapshot | Bin 0 -> 2669 bytes
...ession-with-stateful-trigger-mint-flink1.13-snapshot | Bin 0 -> 2163 bytes
.../list-view-serializer-1.13/serializer-snapshot | Bin 0 -> 269 bytes
.../test/resources/list-view-serializer-1.13/test-data | Bin 0 -> 16 bytes
.../map-view-serializer-1.13/serializer-snapshot | Bin 0 -> 351 bytes
.../test/resources/map-view-serializer-1.13/test-data | Bin 0 -> 11 bytes
.../utils/StatefulJobSavepointMigrationITCase.java | 4 +++-
.../StatefulJobWBroadcastStateMigrationITCase.java | 4 +++-
.../TypeSerializerSnapshotMigrationITCase.java | 4 +++-
.../keyed/AbstractKeyedOperatorRestoreTestBase.java | 3 ++-
.../AbstractNonKeyedOperatorRestoreTestBase.java | 3 ++-
.../_metadata | Bin 0 -> 13838 bytes
.../_metadata | Bin 0 -> 13838 bytes
.../_metadata | Bin 0 -> 17257 bytes
.../_metadata | Bin 0 -> 17257 bytes
.../operatorstate/complexKeyed-flink1.13/_metadata | Bin 0 -> 13772 bytes
.../operatorstate/nonKeyed-flink1.13/_metadata | Bin 0 -> 3693 bytes
.../_metadata | Bin 0 -> 41962 bytes
.../_metadata | Bin 0 -> 41962 bytes
.../_metadata | Bin 0 -> 53733 bytes
.../_metadata | Bin 0 -> 53733 bytes
.../_metadata | Bin 0 -> 1266 bytes
.../_metadata | Bin 0 -> 1266 bytes
.../migration/StatefulJobSavepointMigrationITCase.scala | 4 +++-
.../StatefulJobWBroadcastStateMigrationITCase.scala | 4 +++-
263 files changed, 50 insertions(+), 15 deletions(-)
diff --git a/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBaseMigrationTest.java b/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBaseMigrationTest.java
index bfc565c..cffbff5 100644
--- a/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBaseMigrationTest.java
+++ b/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBaseMigrationTest.java
@@ -103,7 +103,8 @@ public class FlinkKafkaConsumerBaseMigrationTest {
MigrationVersion.v1_9,
MigrationVersion.v1_10,
MigrationVersion.v1_11,
- MigrationVersion.v1_12);
+ MigrationVersion.v1_12,
+ MigrationVersion.v1_13);
}
public FlinkKafkaConsumerBaseMigrationTest(MigrationVersion testMigrateVersion) {
diff --git a/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerMigrationTest.java b/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerMigrationTest.java
index ac32679..1fa1bc6 100644
--- a/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerMigrationTest.java
+++ b/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerMigrationTest.java
@@ -48,7 +48,8 @@ public class FlinkKafkaProducerMigrationTest extends KafkaMigrationTestBase {
MigrationVersion.v1_9,
MigrationVersion.v1_10,
MigrationVersion.v1_11,
- MigrationVersion.v1_12);
+ MigrationVersion.v1_12,
+ MigrationVersion.v1_13);
}
public FlinkKafkaProducerMigrationTest(MigrationVersion testMigrateVersion) {
diff --git a/flink-connectors/flink-connector-kafka/src/test/resources/context-state-serializer-1.13/serializer-snapshot b/flink-connectors/flink-connector-kafka/src/test/resources/context-state-serializer-1.13/serializer-snapshot
new file mode 100644
index 0000000..85a71dc
Binary files /dev/null and b/flink-connectors/flink-connector-kafka/src/test/resources/context-state-serializer-1.13/serializer-snapshot differ
diff --git a/flink-connectors/flink-connector-kafka/src/test/resources/context-state-serializer-1.13/test-data b/flink-connectors/flink-connector-kafka/src/test/resources/context-state-serializer-1.13/test-data
new file mode 100644
index 0000000..3efe488
Binary files /dev/null and b/flink-connectors/flink-connector-kafka/src/test/resources/context-state-serializer-1.13/test-data differ
diff --git a/flink-connectors/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.13-empty-state-snapshot b/flink-connectors/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.13-empty-state-snapshot
new file mode 100644
index 0000000..b472cdd
Binary files /dev/null and b/flink-connectors/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.13-empty-state-snapshot differ
diff --git a/flink-connectors/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.13-snapshot b/flink-connectors/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.13-snapshot
new file mode 100644
index 0000000..ac2ac1c
Binary files /dev/null and b/flink-connectors/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.13-snapshot differ
diff --git a/flink-connectors/flink-connector-kafka/src/test/resources/kafka-migration-kafka-producer-flink-1.13-snapshot b/flink-connectors/flink-connector-kafka/src/test/resources/kafka-migration-kafka-producer-flink-1.13-snapshot
new file mode 100644
index 0000000..9b15b9e
Binary files /dev/null and b/flink-connectors/flink-connector-kafka/src/test/resources/kafka-migration-kafka-producer-flink-1.13-snapshot differ
diff --git a/flink-connectors/flink-connector-kafka/src/test/resources/transaction-state-serializer-1.13/serializer-snapshot b/flink-connectors/flink-connector-kafka/src/test/resources/transaction-state-serializer-1.13/serializer-snapshot
new file mode 100644
index 0000000..b95eacb
Binary files /dev/null and b/flink-connectors/flink-connector-kafka/src/test/resources/transaction-state-serializer-1.13/serializer-snapshot differ
diff --git a/flink-connectors/flink-connector-kafka/src/test/resources/transaction-state-serializer-1.13/test-data b/flink-connectors/flink-connector-kafka/src/test/resources/transaction-state-serializer-1.13/test-data
new file mode 100644
index 0000000..0936509
Binary files /dev/null and b/flink-connectors/flink-connector-kafka/src/test/resources/transaction-state-serializer-1.13/test-data differ
diff --git a/flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumerMigrationTest.java b/flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumerMigrationTest.java
index 28595fe..7a8dca4 100644
--- a/flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumerMigrationTest.java
+++ b/flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumerMigrationTest.java
@@ -106,7 +106,8 @@ public class FlinkKinesisConsumerMigrationTest {
MigrationVersion.v1_9,
MigrationVersion.v1_10,
MigrationVersion.v1_11,
- MigrationVersion.v1_12);
+ MigrationVersion.v1_12,
+ MigrationVersion.v1_13);
}
public FlinkKinesisConsumerMigrationTest(MigrationVersion testMigrateVersion) {
diff --git a/flink-connectors/flink-connector-kinesis/src/test/resources/kinesis-consumer-migration-test-flink1.13-empty-snapshot b/flink-connectors/flink-connector-kinesis/src/test/resources/kinesis-consumer-migration-test-flink1.13-empty-snapshot
new file mode 100644
index 0000000..46959c0
Binary files /dev/null and b/flink-connectors/flink-connector-kinesis/src/test/resources/kinesis-consumer-migration-test-flink1.13-empty-snapshot differ
diff --git a/flink-connectors/flink-connector-kinesis/src/test/resources/kinesis-consumer-migration-test-flink1.13-snapshot b/flink-connectors/flink-connector-kinesis/src/test/resources/kinesis-consumer-migration-test-flink1.13-snapshot
new file mode 100644
index 0000000..5bb6d2b
Binary files /dev/null and b/flink-connectors/flink-connector-kinesis/src/test/resources/kinesis-consumer-migration-test-flink1.13-snapshot differ
diff --git a/flink-connectors/flink-hadoop-compatibility/src/test/resources/writeable-serializer-1.13/serializer-snapshot b/flink-connectors/flink-hadoop-compatibility/src/test/resources/writeable-serializer-1.13/serializer-snapshot
new file mode 100644
index 0000000..0af5d65
Binary files /dev/null and b/flink-connectors/flink-hadoop-compatibility/src/test/resources/writeable-serializer-1.13/serializer-snapshot differ
diff --git a/flink-connectors/flink-hadoop-compatibility/src/test/resources/writeable-serializer-1.13/test-data b/flink-connectors/flink-hadoop-compatibility/src/test/resources/writeable-serializer-1.13/test-data
new file mode 100644
index 0000000..f43afae
Binary files /dev/null and b/flink-connectors/flink-hadoop-compatibility/src/test/resources/writeable-serializer-1.13/test-data differ
diff --git a/flink-core/src/test/java/org/apache/flink/api/common/typeutils/TypeSerializerUpgradeTestBase.java b/flink-core/src/test/java/org/apache/flink/api/common/typeutils/TypeSerializerUpgradeTestBase.java
index ced0632..9751e2d 100644
--- a/flink-core/src/test/java/org/apache/flink/api/common/typeutils/TypeSerializerUpgradeTestBase.java
+++ b/flink-core/src/test/java/org/apache/flink/api/common/typeutils/TypeSerializerUpgradeTestBase.java
@@ -54,7 +54,7 @@ public abstract class TypeSerializerUpgradeTestBase<PreviousElementT, UpgradedEl
public static final MigrationVersion[] MIGRATION_VERSIONS =
MigrationVersion.v1_11.orHigher().toArray(new MigrationVersion[0]);
- public static final MigrationVersion CURRENT_VERSION = MigrationVersion.v1_12;
+ public static final MigrationVersion CURRENT_VERSION = MigrationVersion.v1_13;
private final TestSpecification<PreviousElementT, UpgradedElementT> testSpecification;
diff --git a/flink-core/src/test/java/org/apache/flink/testutils/migration/MigrationVersion.java b/flink-core/src/test/java/org/apache/flink/testutils/migration/MigrationVersion.java
index 70322eb..d024382 100644
--- a/flink-core/src/test/java/org/apache/flink/testutils/migration/MigrationVersion.java
+++ b/flink-core/src/test/java/org/apache/flink/testutils/migration/MigrationVersion.java
@@ -44,7 +44,8 @@ public enum MigrationVersion {
v1_9("1.9"),
v1_10("1.10"),
v1_11("1.11"),
- v1_12("1.12");
+ v1_12("1.12"),
+ v1_13("1.13");
private final String versionStr;
diff --git a/flink-core/src/test/resources/big-dec-serializer-1.13/serializer-snapshot b/flink-core/src/test/resources/big-dec-serializer-1.13/serializer-snapshot
new file mode 100644
index 0000000..ccd31f3
Binary files /dev/null and b/flink-core/src/test/resources/big-dec-serializer-1.13/serializer-snapshot differ
diff --git a/flink-core/src/test/resources/big-dec-serializer-1.13/test-data b/flink-core/src/test/resources/big-dec-serializer-1.13/test-data
new file mode 100644
index 0000000..c59e432
Binary files /dev/null and b/flink-core/src/test/resources/big-dec-serializer-1.13/test-data differ
diff --git a/flink-core/src/test/resources/big-int-serializer-1.13/serializer-snapshot b/flink-core/src/test/resources/big-int-serializer-1.13/serializer-snapshot
new file mode 100644
index 0000000..b525669
Binary files /dev/null and b/flink-core/src/test/resources/big-int-serializer-1.13/serializer-snapshot differ
diff --git a/flink-core/src/test/resources/big-int-serializer-1.13/test-data b/flink-core/src/test/resources/big-int-serializer-1.13/test-data
new file mode 100644
index 0000000..3d0079e
Binary files /dev/null and b/flink-core/src/test/resources/big-int-serializer-1.13/test-data differ
diff --git a/flink-core/src/test/resources/boolean-primitive-array-serializer-1.13/serializer-snapshot b/flink-core/src/test/resources/boolean-primitive-array-serializer-1.13/serializer-snapshot
new file mode 100644
index 0000000..dfa6707
Binary files /dev/null and b/flink-core/src/test/resources/boolean-primitive-array-serializer-1.13/serializer-snapshot differ
diff --git a/flink-core/src/test/resources/boolean-primitive-array-serializer-1.13/test-data b/flink-core/src/test/resources/boolean-primitive-array-serializer-1.13/test-data
new file mode 100644
index 0000000..0e3eeb5
Binary files /dev/null and b/flink-core/src/test/resources/boolean-primitive-array-serializer-1.13/test-data differ
diff --git a/flink-core/src/test/resources/boolean-serializer-1.13/serializer-snapshot b/flink-core/src/test/resources/boolean-serializer-1.13/serializer-snapshot
new file mode 100644
index 0000000..b1e867b
Binary files /dev/null and b/flink-core/src/test/resources/boolean-serializer-1.13/serializer-snapshot differ
diff --git a/flink-core/src/test/resources/boolean-serializer-1.13/test-data b/flink-core/src/test/resources/boolean-serializer-1.13/test-data
new file mode 100644
index 0000000..6b2aaa7
--- /dev/null
+++ b/flink-core/src/test/resources/boolean-serializer-1.13/test-data
@@ -0,0 +1 @@
+
\ No newline at end of file
diff --git a/flink-core/src/test/resources/boolean-value-serializer-1.13/serializer-snapshot b/flink-core/src/test/resources/boolean-value-serializer-1.13/serializer-snapshot
new file mode 100644
index 0000000..8511a73
Binary files /dev/null and b/flink-core/src/test/resources/boolean-value-serializer-1.13/serializer-snapshot differ
diff --git a/flink-core/src/test/resources/boolean-value-serializer-1.13/test-data b/flink-core/src/test/resources/boolean-value-serializer-1.13/test-data
new file mode 100644
index 0000000..6b2aaa7
--- /dev/null
+++ b/flink-core/src/test/resources/boolean-value-serializer-1.13/test-data
@@ -0,0 +1 @@
+
\ No newline at end of file
diff --git a/flink-core/src/test/resources/byte-primitive-array-serializer-1.13/serializer-snapshot b/flink-core/src/test/resources/byte-primitive-array-serializer-1.13/serializer-snapshot
new file mode 100644
index 0000000..071fdfd
Binary files /dev/null and b/flink-core/src/test/resources/byte-primitive-array-serializer-1.13/serializer-snapshot differ
diff --git a/flink-core/src/test/resources/byte-primitive-array-serializer-1.13/test-data b/flink-core/src/test/resources/byte-primitive-array-serializer-1.13/test-data
new file mode 100644
index 0000000..1ea699b
Binary files /dev/null and b/flink-core/src/test/resources/byte-primitive-array-serializer-1.13/test-data differ
diff --git a/flink-core/src/test/resources/byte-serializer-1.13/serializer-snapshot b/flink-core/src/test/resources/byte-serializer-1.13/serializer-snapshot
new file mode 100644
index 0000000..372634d
Binary files /dev/null and b/flink-core/src/test/resources/byte-serializer-1.13/serializer-snapshot differ
diff --git a/flink-core/src/test/resources/byte-serializer-1.13/test-data b/flink-core/src/test/resources/byte-serializer-1.13/test-data
new file mode 100644
index 0000000..f59ec20
--- /dev/null
+++ b/flink-core/src/test/resources/byte-serializer-1.13/test-data
@@ -0,0 +1 @@
+*
\ No newline at end of file
diff --git a/flink-core/src/test/resources/byte-value-serializer-1.13/serializer-snapshot b/flink-core/src/test/resources/byte-value-serializer-1.13/serializer-snapshot
new file mode 100644
index 0000000..af6c1f0
Binary files /dev/null and b/flink-core/src/test/resources/byte-value-serializer-1.13/serializer-snapshot differ
diff --git a/flink-core/src/test/resources/byte-value-serializer-1.13/test-data b/flink-core/src/test/resources/byte-value-serializer-1.13/test-data
new file mode 100644
index 0000000..f59ec20
--- /dev/null
+++ b/flink-core/src/test/resources/byte-value-serializer-1.13/test-data
@@ -0,0 +1 @@
+*
\ No newline at end of file
diff --git a/flink-core/src/test/resources/char-primitive-array-serializer-1.13/serializer-snapshot b/flink-core/src/test/resources/char-primitive-array-serializer-1.13/serializer-snapshot
new file mode 100644
index 0000000..31a3a34
Binary files /dev/null and b/flink-core/src/test/resources/char-primitive-array-serializer-1.13/serializer-snapshot differ
diff --git a/flink-core/src/test/resources/char-primitive-array-serializer-1.13/test-data b/flink-core/src/test/resources/char-primitive-array-serializer-1.13/test-data
new file mode 100644
index 0000000..cc4337b
Binary files /dev/null and b/flink-core/src/test/resources/char-primitive-array-serializer-1.13/test-data differ
diff --git a/flink-core/src/test/resources/char-serializer-1.13/serializer-snapshot b/flink-core/src/test/resources/char-serializer-1.13/serializer-snapshot
new file mode 100644
index 0000000..5f6308d
Binary files /dev/null and b/flink-core/src/test/resources/char-serializer-1.13/serializer-snapshot differ
diff --git a/flink-core/src/test/resources/char-serializer-1.13/test-data b/flink-core/src/test/resources/char-serializer-1.13/test-data
new file mode 100644
index 0000000..f96c401
--- /dev/null
+++ b/flink-core/src/test/resources/char-serializer-1.13/test-data
@@ -0,0 +1 @@
+��
\ No newline at end of file
diff --git a/flink-core/src/test/resources/char-value-serializer-1.13/serializer-snapshot b/flink-core/src/test/resources/char-value-serializer-1.13/serializer-snapshot
new file mode 100644
index 0000000..67c2a46
Binary files /dev/null and b/flink-core/src/test/resources/char-value-serializer-1.13/serializer-snapshot differ
diff --git a/flink-core/src/test/resources/char-value-serializer-1.13/test-data b/flink-core/src/test/resources/char-value-serializer-1.13/test-data
new file mode 100644
index 0000000..d399cc0
Binary files /dev/null and b/flink-core/src/test/resources/char-value-serializer-1.13/test-data differ
diff --git a/flink-core/src/test/resources/copyable-value-serializer-1.13/serializer-snapshot b/flink-core/src/test/resources/copyable-value-serializer-1.13/serializer-snapshot
new file mode 100644
index 0000000..f1b8eb6
Binary files /dev/null and b/flink-core/src/test/resources/copyable-value-serializer-1.13/serializer-snapshot differ
diff --git a/flink-core/src/test/resources/copyable-value-serializer-1.13/test-data b/flink-core/src/test/resources/copyable-value-serializer-1.13/test-data
new file mode 100644
index 0000000..9ff9b97
Binary files /dev/null and b/flink-core/src/test/resources/copyable-value-serializer-1.13/test-data differ
diff --git a/flink-core/src/test/resources/date-serializer-1.13/serializer-snapshot b/flink-core/src/test/resources/date-serializer-1.13/serializer-snapshot
new file mode 100644
index 0000000..4794ebd
Binary files /dev/null and b/flink-core/src/test/resources/date-serializer-1.13/serializer-snapshot differ
diff --git a/flink-core/src/test/resources/date-serializer-1.13/test-data b/flink-core/src/test/resources/date-serializer-1.13/test-data
new file mode 100644
index 0000000..1faf9a0
Binary files /dev/null and b/flink-core/src/test/resources/date-serializer-1.13/test-data differ
diff --git a/flink-core/src/test/resources/double-primitive-array-serializer-1.13/serializer-snapshot b/flink-core/src/test/resources/double-primitive-array-serializer-1.13/serializer-snapshot
new file mode 100644
index 0000000..98ae2a6
Binary files /dev/null and b/flink-core/src/test/resources/double-primitive-array-serializer-1.13/serializer-snapshot differ
diff --git a/flink-core/src/test/resources/double-primitive-array-serializer-1.13/test-data b/flink-core/src/test/resources/double-primitive-array-serializer-1.13/test-data
new file mode 100644
index 0000000..349e318
Binary files /dev/null and b/flink-core/src/test/resources/double-primitive-array-serializer-1.13/test-data differ
diff --git a/flink-core/src/test/resources/double-serializer-1.13/serializer-snapshot b/flink-core/src/test/resources/double-serializer-1.13/serializer-snapshot
new file mode 100644
index 0000000..1383b64
Binary files /dev/null and b/flink-core/src/test/resources/double-serializer-1.13/serializer-snapshot differ
diff --git a/flink-core/src/test/resources/double-serializer-1.13/test-data b/flink-core/src/test/resources/double-serializer-1.13/test-data
new file mode 100644
index 0000000..5cfd371
--- /dev/null
+++ b/flink-core/src/test/resources/double-serializer-1.13/test-data
@@ -0,0 +1 @@
+@� ��1��
\ No newline at end of file
diff --git a/flink-core/src/test/resources/double-value-serializer-1.13/serializer-snapshot b/flink-core/src/test/resources/double-value-serializer-1.13/serializer-snapshot
new file mode 100644
index 0000000..604cef8
Binary files /dev/null and b/flink-core/src/test/resources/double-value-serializer-1.13/serializer-snapshot differ
diff --git a/flink-core/src/test/resources/double-value-serializer-1.13/test-data b/flink-core/src/test/resources/double-value-serializer-1.13/test-data
new file mode 100644
index 0000000..5cfd371
--- /dev/null
+++ b/flink-core/src/test/resources/double-value-serializer-1.13/test-data
@@ -0,0 +1 @@
+@� ��1��
\ No newline at end of file
diff --git a/flink-core/src/test/resources/either-serializer-1.13/serializer-snapshot b/flink-core/src/test/resources/either-serializer-1.13/serializer-snapshot
new file mode 100644
index 0000000..9357df7
Binary files /dev/null and b/flink-core/src/test/resources/either-serializer-1.13/serializer-snapshot differ
diff --git a/flink-core/src/test/resources/either-serializer-1.13/test-data b/flink-core/src/test/resources/either-serializer-1.13/test-data
new file mode 100644
index 0000000..87ec446
--- /dev/null
+++ b/flink-core/src/test/resources/either-serializer-1.13/test-data
@@ -0,0 +1 @@
+ ApacheFlink
\ No newline at end of file
diff --git a/flink-core/src/test/resources/enum-serializer-1.13/serializer-snapshot b/flink-core/src/test/resources/enum-serializer-1.13/serializer-snapshot
new file mode 100644
index 0000000..27cc1da
Binary files /dev/null and b/flink-core/src/test/resources/enum-serializer-1.13/serializer-snapshot differ
diff --git a/flink-core/src/test/resources/enum-serializer-1.13/test-data b/flink-core/src/test/resources/enum-serializer-1.13/test-data
new file mode 100644
index 0000000..3b6fc84
Binary files /dev/null and b/flink-core/src/test/resources/enum-serializer-1.13/test-data differ
diff --git a/flink-core/src/test/resources/enum-serializerreconfig-1.13/serializer-snapshot b/flink-core/src/test/resources/enum-serializerreconfig-1.13/serializer-snapshot
new file mode 100644
index 0000000..a43be8d
Binary files /dev/null and b/flink-core/src/test/resources/enum-serializerreconfig-1.13/serializer-snapshot differ
diff --git a/flink-core/src/test/resources/enum-serializerreconfig-1.13/test-data b/flink-core/src/test/resources/enum-serializerreconfig-1.13/test-data
new file mode 100644
index 0000000..ded2df2
Binary files /dev/null and b/flink-core/src/test/resources/enum-serializerreconfig-1.13/test-data differ
diff --git a/flink-core/src/test/resources/float-primitive-array-serializer-1.13/serializer-snapshot b/flink-core/src/test/resources/float-primitive-array-serializer-1.13/serializer-snapshot
new file mode 100644
index 0000000..7342807
Binary files /dev/null and b/flink-core/src/test/resources/float-primitive-array-serializer-1.13/serializer-snapshot differ
diff --git a/flink-core/src/test/resources/float-primitive-array-serializer-1.13/test-data b/flink-core/src/test/resources/float-primitive-array-serializer-1.13/test-data
new file mode 100644
index 0000000..cb6654f
Binary files /dev/null and b/flink-core/src/test/resources/float-primitive-array-serializer-1.13/test-data differ
diff --git a/flink-core/src/test/resources/float-serializer-1.13/serializer-snapshot b/flink-core/src/test/resources/float-serializer-1.13/serializer-snapshot
new file mode 100644
index 0000000..62370bd
Binary files /dev/null and b/flink-core/src/test/resources/float-serializer-1.13/serializer-snapshot differ
diff --git a/flink-core/src/test/resources/float-serializer-1.13/test-data b/flink-core/src/test/resources/float-serializer-1.13/test-data
new file mode 100644
index 0000000..f9c0e21
--- /dev/null
+++ b/flink-core/src/test/resources/float-serializer-1.13/test-data
@@ -0,0 +1 @@
+B��y
\ No newline at end of file
diff --git a/flink-core/src/test/resources/float-value-serializer-1.13/serializer-snapshot b/flink-core/src/test/resources/float-value-serializer-1.13/serializer-snapshot
new file mode 100644
index 0000000..6100e57
Binary files /dev/null and b/flink-core/src/test/resources/float-value-serializer-1.13/serializer-snapshot differ
diff --git a/flink-core/src/test/resources/float-value-serializer-1.13/test-data b/flink-core/src/test/resources/float-value-serializer-1.13/test-data
new file mode 100644
index 0000000..f9c0e21
--- /dev/null
+++ b/flink-core/src/test/resources/float-value-serializer-1.13/test-data
@@ -0,0 +1 @@
+B��y
\ No newline at end of file
diff --git a/flink-core/src/test/resources/generic-array-serializer-1.13/serializer-snapshot b/flink-core/src/test/resources/generic-array-serializer-1.13/serializer-snapshot
new file mode 100644
index 0000000..2bb4df4
Binary files /dev/null and b/flink-core/src/test/resources/generic-array-serializer-1.13/serializer-snapshot differ
diff --git a/flink-core/src/test/resources/generic-array-serializer-1.13/test-data b/flink-core/src/test/resources/generic-array-serializer-1.13/test-data
new file mode 100644
index 0000000..6d06a98
Binary files /dev/null and b/flink-core/src/test/resources/generic-array-serializer-1.13/test-data differ
diff --git a/flink-core/src/test/resources/int-primitive-array-serializer-1.13/serializer-snapshot b/flink-core/src/test/resources/int-primitive-array-serializer-1.13/serializer-snapshot
new file mode 100644
index 0000000..2087b50
Binary files /dev/null and b/flink-core/src/test/resources/int-primitive-array-serializer-1.13/serializer-snapshot differ
diff --git a/flink-core/src/test/resources/int-primitive-array-serializer-1.13/test-data b/flink-core/src/test/resources/int-primitive-array-serializer-1.13/test-data
new file mode 100644
index 0000000..dd766c0
Binary files /dev/null and b/flink-core/src/test/resources/int-primitive-array-serializer-1.13/test-data differ
diff --git a/flink-core/src/test/resources/int-serializer-1.13/serializer-snapshot b/flink-core/src/test/resources/int-serializer-1.13/serializer-snapshot
new file mode 100644
index 0000000..597fc6b
Binary files /dev/null and b/flink-core/src/test/resources/int-serializer-1.13/serializer-snapshot differ
diff --git a/flink-core/src/test/resources/int-serializer-1.13/test-data b/flink-core/src/test/resources/int-serializer-1.13/test-data
new file mode 100644
index 0000000..e9271b3
Binary files /dev/null and b/flink-core/src/test/resources/int-serializer-1.13/test-data differ
diff --git a/flink-core/src/test/resources/int-value-serializer-1.13/serializer-snapshot b/flink-core/src/test/resources/int-value-serializer-1.13/serializer-snapshot
new file mode 100644
index 0000000..f6ae072
Binary files /dev/null and b/flink-core/src/test/resources/int-value-serializer-1.13/serializer-snapshot differ
diff --git a/flink-core/src/test/resources/int-value-serializer-1.13/test-data b/flink-core/src/test/resources/int-value-serializer-1.13/test-data
new file mode 100644
index 0000000..e9271b3
Binary files /dev/null and b/flink-core/src/test/resources/int-value-serializer-1.13/test-data differ
diff --git a/flink-core/src/test/resources/kryo-custom-type-serializer-changed-registration-order-1.13/serializer-snapshot b/flink-core/src/test/resources/kryo-custom-type-serializer-changed-registration-order-1.13/serializer-snapshot
new file mode 100644
index 0000000..07b541e
Binary files /dev/null and b/flink-core/src/test/resources/kryo-custom-type-serializer-changed-registration-order-1.13/serializer-snapshot differ
diff --git a/flink-core/src/test/resources/kryo-custom-type-serializer-changed-registration-order-1.13/test-data b/flink-core/src/test/resources/kryo-custom-type-serializer-changed-registration-order-1.13/test-data
new file mode 100644
index 0000000..ea0b75f
--- /dev/null
+++ b/flink-core/src/test/resources/kryo-custom-type-serializer-changed-registration-order-1.13/test-data
@@ -0,0 +1 @@
+Hass�
\ No newline at end of file
diff --git a/flink-core/src/test/resources/kryo-type-serializer-changed-registration-order-1.13/serializer-snapshot b/flink-core/src/test/resources/kryo-type-serializer-changed-registration-order-1.13/serializer-snapshot
new file mode 100644
index 0000000..ec2538c
Binary files /dev/null and b/flink-core/src/test/resources/kryo-type-serializer-changed-registration-order-1.13/serializer-snapshot differ
diff --git a/flink-core/src/test/resources/kryo-type-serializer-changed-registration-order-1.13/test-data b/flink-core/src/test/resources/kryo-type-serializer-changed-registration-order-1.13/test-data
new file mode 100644
index 0000000..f8f9b83
--- /dev/null
+++ b/flink-core/src/test/resources/kryo-type-serializer-changed-registration-order-1.13/test-data
@@ -0,0 +1 @@
+
Hass�
\ No newline at end of file
diff --git a/flink-core/src/test/resources/kryo-type-serializer-empty-config-1.13/serializer-snapshot b/flink-core/src/test/resources/kryo-type-serializer-empty-config-1.13/serializer-snapshot
new file mode 100644
index 0000000..b755573
Binary files /dev/null and b/flink-core/src/test/resources/kryo-type-serializer-empty-config-1.13/serializer-snapshot differ
diff --git a/flink-core/src/test/resources/kryo-type-serializer-empty-config-1.13/test-data b/flink-core/src/test/resources/kryo-type-serializer-empty-config-1.13/test-data
new file mode 100644
index 0000000..517b98e
Binary files /dev/null and b/flink-core/src/test/resources/kryo-type-serializer-empty-config-1.13/test-data differ
diff --git a/flink-core/src/test/resources/kryo-type-serializer-unrelated-config-after-restore-1.13/serializer-snapshot b/flink-core/src/test/resources/kryo-type-serializer-unrelated-config-after-restore-1.13/serializer-snapshot
new file mode 100644
index 0000000..b755573
Binary files /dev/null and b/flink-core/src/test/resources/kryo-type-serializer-unrelated-config-after-restore-1.13/serializer-snapshot differ
diff --git a/flink-core/src/test/resources/kryo-type-serializer-unrelated-config-after-restore-1.13/test-data b/flink-core/src/test/resources/kryo-type-serializer-unrelated-config-after-restore-1.13/test-data
new file mode 100644
index 0000000..517b98e
Binary files /dev/null and b/flink-core/src/test/resources/kryo-type-serializer-unrelated-config-after-restore-1.13/test-data differ
diff --git a/flink-core/src/test/resources/list-serializer-1.13/serializer-snapshot b/flink-core/src/test/resources/list-serializer-1.13/serializer-snapshot
new file mode 100644
index 0000000..bbd86a6
Binary files /dev/null and b/flink-core/src/test/resources/list-serializer-1.13/serializer-snapshot differ
diff --git a/flink-core/src/test/resources/list-serializer-1.13/test-data b/flink-core/src/test/resources/list-serializer-1.13/test-data
new file mode 100644
index 0000000..ac79859
Binary files /dev/null and b/flink-core/src/test/resources/list-serializer-1.13/test-data differ
diff --git a/flink-core/src/test/resources/long-primitive-array-serializer-1.13/serializer-snapshot b/flink-core/src/test/resources/long-primitive-array-serializer-1.13/serializer-snapshot
new file mode 100644
index 0000000..6bf0336
Binary files /dev/null and b/flink-core/src/test/resources/long-primitive-array-serializer-1.13/serializer-snapshot differ
diff --git a/flink-core/src/test/resources/long-primitive-array-serializer-1.13/test-data b/flink-core/src/test/resources/long-primitive-array-serializer-1.13/test-data
new file mode 100644
index 0000000..873fe64
Binary files /dev/null and b/flink-core/src/test/resources/long-primitive-array-serializer-1.13/test-data differ
diff --git a/flink-core/src/test/resources/long-serializer-1.13/serializer-snapshot b/flink-core/src/test/resources/long-serializer-1.13/serializer-snapshot
new file mode 100644
index 0000000..4f51b34
Binary files /dev/null and b/flink-core/src/test/resources/long-serializer-1.13/serializer-snapshot differ
diff --git a/flink-core/src/test/resources/long-serializer-1.13/test-data b/flink-core/src/test/resources/long-serializer-1.13/test-data
new file mode 100644
index 0000000..2ffef6c
Binary files /dev/null and b/flink-core/src/test/resources/long-serializer-1.13/test-data differ
diff --git a/flink-core/src/test/resources/long-value-serializer-1.13/serializer-snapshot b/flink-core/src/test/resources/long-value-serializer-1.13/serializer-snapshot
new file mode 100644
index 0000000..b9e8f69
Binary files /dev/null and b/flink-core/src/test/resources/long-value-serializer-1.13/serializer-snapshot differ
diff --git a/flink-core/src/test/resources/long-value-serializer-1.13/test-data b/flink-core/src/test/resources/long-value-serializer-1.13/test-data
new file mode 100644
index 0000000..2ffef6c
Binary files /dev/null and b/flink-core/src/test/resources/long-value-serializer-1.13/test-data differ
diff --git a/flink-core/src/test/resources/map-serializer-1.13/serializer-snapshot b/flink-core/src/test/resources/map-serializer-1.13/serializer-snapshot
new file mode 100644
index 0000000..6d47ba4
Binary files /dev/null and b/flink-core/src/test/resources/map-serializer-1.13/serializer-snapshot differ
diff --git a/flink-core/src/test/resources/map-serializer-1.13/test-data b/flink-core/src/test/resources/map-serializer-1.13/test-data
new file mode 100644
index 0000000..8999b1f
Binary files /dev/null and b/flink-core/src/test/resources/map-serializer-1.13/test-data differ
diff --git a/flink-core/src/test/resources/null-value-serializer-1.13/serializer-snapshot b/flink-core/src/test/resources/null-value-serializer-1.13/serializer-snapshot
new file mode 100644
index 0000000..fcecf15
Binary files /dev/null and b/flink-core/src/test/resources/null-value-serializer-1.13/serializer-snapshot differ
diff --git a/flink-core/src/test/resources/null-value-serializer-1.13/test-data b/flink-core/src/test/resources/null-value-serializer-1.13/test-data
new file mode 100644
index 0000000..e69de29
diff --git a/flink-core/src/test/resources/nullable-not-padded-serializer-1.13/serializer-snapshot b/flink-core/src/test/resources/nullable-not-padded-serializer-1.13/serializer-snapshot
new file mode 100644
index 0000000..71c489a
Binary files /dev/null and b/flink-core/src/test/resources/nullable-not-padded-serializer-1.13/serializer-snapshot differ
diff --git a/flink-core/src/test/resources/nullable-not-padded-serializer-1.13/test-data b/flink-core/src/test/resources/nullable-not-padded-serializer-1.13/test-data
new file mode 100644
index 0000000..6b2aaa7
--- /dev/null
+++ b/flink-core/src/test/resources/nullable-not-padded-serializer-1.13/test-data
@@ -0,0 +1 @@
+
\ No newline at end of file
diff --git a/flink-core/src/test/resources/nullable-padded-serializer-1.13/serializer-snapshot b/flink-core/src/test/resources/nullable-padded-serializer-1.13/serializer-snapshot
new file mode 100644
index 0000000..7831be8
Binary files /dev/null and b/flink-core/src/test/resources/nullable-padded-serializer-1.13/serializer-snapshot differ
diff --git a/flink-core/src/test/resources/nullable-padded-serializer-1.13/test-data b/flink-core/src/test/resources/nullable-padded-serializer-1.13/test-data
new file mode 100644
index 0000000..22fd28d
Binary files /dev/null and b/flink-core/src/test/resources/nullable-padded-serializer-1.13/test-data differ
diff --git a/flink-core/src/test/resources/pojo-serializer-identical-schema-1.13/serializer-snapshot b/flink-core/src/test/resources/pojo-serializer-identical-schema-1.13/serializer-snapshot
new file mode 100644
index 0000000..5bded08
Binary files /dev/null and b/flink-core/src/test/resources/pojo-serializer-identical-schema-1.13/serializer-snapshot differ
diff --git a/flink-core/src/test/resources/pojo-serializer-identical-schema-1.13/test-data b/flink-core/src/test/resources/pojo-serializer-identical-schema-1.13/test-data
new file mode 100644
index 0000000..6700223
Binary files /dev/null and b/flink-core/src/test/resources/pojo-serializer-identical-schema-1.13/test-data differ
diff --git a/flink-core/src/test/resources/pojo-serializer-with-different-field-types-1.13/serializer-snapshot b/flink-core/src/test/resources/pojo-serializer-with-different-field-types-1.13/serializer-snapshot
new file mode 100644
index 0000000..a1b44c0
Binary files /dev/null and b/flink-core/src/test/resources/pojo-serializer-with-different-field-types-1.13/serializer-snapshot differ
diff --git a/flink-core/src/test/resources/pojo-serializer-with-different-field-types-1.13/test-data b/flink-core/src/test/resources/pojo-serializer-with-different-field-types-1.13/test-data
new file mode 100644
index 0000000..9cf45f4
Binary files /dev/null and b/flink-core/src/test/resources/pojo-serializer-with-different-field-types-1.13/test-data differ
diff --git a/flink-core/src/test/resources/pojo-serializer-with-different-field-types-in-registered-subclass-1.13/serializer-snapshot b/flink-core/src/test/resources/pojo-serializer-with-different-field-types-in-registered-subclass-1.13/serializer-snapshot
new file mode 100644
index 0000000..9f5609d
Binary files /dev/null and b/flink-core/src/test/resources/pojo-serializer-with-different-field-types-in-registered-subclass-1.13/serializer-snapshot differ
diff --git a/flink-core/src/test/resources/pojo-serializer-with-different-field-types-in-registered-subclass-1.13/test-data b/flink-core/src/test/resources/pojo-serializer-with-different-field-types-in-registered-subclass-1.13/test-data
new file mode 100644
index 0000000..195b040
Binary files /dev/null and b/flink-core/src/test/resources/pojo-serializer-with-different-field-types-in-registered-subclass-1.13/test-data differ
diff --git a/flink-core/src/test/resources/pojo-serializer-with-different-subclass-registration-order-1.13/serializer-snapshot b/flink-core/src/test/resources/pojo-serializer-with-different-subclass-registration-order-1.13/serializer-snapshot
new file mode 100644
index 0000000..e771338
Binary files /dev/null and b/flink-core/src/test/resources/pojo-serializer-with-different-subclass-registration-order-1.13/serializer-snapshot differ
diff --git a/flink-core/src/test/resources/pojo-serializer-with-different-subclass-registration-order-1.13/test-data b/flink-core/src/test/resources/pojo-serializer-with-different-subclass-registration-order-1.13/test-data
new file mode 100644
index 0000000..d1569d8
Binary files /dev/null and b/flink-core/src/test/resources/pojo-serializer-with-different-subclass-registration-order-1.13/test-data differ
diff --git a/flink-core/src/test/resources/pojo-serializer-with-missing-registered-subclass-1.13/serializer-snapshot b/flink-core/src/test/resources/pojo-serializer-with-missing-registered-subclass-1.13/serializer-snapshot
new file mode 100644
index 0000000..e771338
Binary files /dev/null and b/flink-core/src/test/resources/pojo-serializer-with-missing-registered-subclass-1.13/serializer-snapshot differ
diff --git a/flink-core/src/test/resources/pojo-serializer-with-missing-registered-subclass-1.13/test-data b/flink-core/src/test/resources/pojo-serializer-with-missing-registered-subclass-1.13/test-data
new file mode 100644
index 0000000..d1569d8
Binary files /dev/null and b/flink-core/src/test/resources/pojo-serializer-with-missing-registered-subclass-1.13/test-data differ
diff --git a/flink-core/src/test/resources/pojo-serializer-with-modified-schema-1.13/serializer-snapshot b/flink-core/src/test/resources/pojo-serializer-with-modified-schema-1.13/serializer-snapshot
new file mode 100644
index 0000000..63bf2dc
Binary files /dev/null and b/flink-core/src/test/resources/pojo-serializer-with-modified-schema-1.13/serializer-snapshot differ
diff --git a/flink-core/src/test/resources/pojo-serializer-with-modified-schema-1.13/test-data b/flink-core/src/test/resources/pojo-serializer-with-modified-schema-1.13/test-data
new file mode 100644
index 0000000..0ce0677
Binary files /dev/null and b/flink-core/src/test/resources/pojo-serializer-with-modified-schema-1.13/test-data differ
diff --git a/flink-core/src/test/resources/pojo-serializer-with-modified-schema-in-registered-subclass-1.13/serializer-snapshot b/flink-core/src/test/resources/pojo-serializer-with-modified-schema-in-registered-subclass-1.13/serializer-snapshot
new file mode 100644
index 0000000..5868d77
Binary files /dev/null and b/flink-core/src/test/resources/pojo-serializer-with-modified-schema-in-registered-subclass-1.13/serializer-snapshot differ
diff --git a/flink-core/src/test/resources/pojo-serializer-with-modified-schema-in-registered-subclass-1.13/test-data b/flink-core/src/test/resources/pojo-serializer-with-modified-schema-in-registered-subclass-1.13/test-data
new file mode 100644
index 0000000..9d83d0b
Binary files /dev/null and b/flink-core/src/test/resources/pojo-serializer-with-modified-schema-in-registered-subclass-1.13/test-data differ
diff --git a/flink-core/src/test/resources/pojo-serializer-with-new-and-missing-registered-subclasses-1.13/serializer-snapshot b/flink-core/src/test/resources/pojo-serializer-with-new-and-missing-registered-subclasses-1.13/serializer-snapshot
new file mode 100644
index 0000000..e771338
Binary files /dev/null and b/flink-core/src/test/resources/pojo-serializer-with-new-and-missing-registered-subclasses-1.13/serializer-snapshot differ
diff --git a/flink-core/src/test/resources/pojo-serializer-with-new-and-missing-registered-subclasses-1.13/test-data b/flink-core/src/test/resources/pojo-serializer-with-new-and-missing-registered-subclasses-1.13/test-data
new file mode 100644
index 0000000..d1569d8
Binary files /dev/null and b/flink-core/src/test/resources/pojo-serializer-with-new-and-missing-registered-subclasses-1.13/test-data differ
diff --git a/flink-core/src/test/resources/pojo-serializer-with-new-registered-subclass-1.13/serializer-snapshot b/flink-core/src/test/resources/pojo-serializer-with-new-registered-subclass-1.13/serializer-snapshot
new file mode 100644
index 0000000..5bf16ff
Binary files /dev/null and b/flink-core/src/test/resources/pojo-serializer-with-new-registered-subclass-1.13/serializer-snapshot differ
diff --git a/flink-core/src/test/resources/pojo-serializer-with-new-registered-subclass-1.13/test-data b/flink-core/src/test/resources/pojo-serializer-with-new-registered-subclass-1.13/test-data
new file mode 100644
index 0000000..10ca450
Binary files /dev/null and b/flink-core/src/test/resources/pojo-serializer-with-new-registered-subclass-1.13/test-data differ
diff --git a/flink-core/src/test/resources/pojo-serializer-with-non-registered-subclass-1.13/serializer-snapshot b/flink-core/src/test/resources/pojo-serializer-with-non-registered-subclass-1.13/serializer-snapshot
new file mode 100644
index 0000000..5bf16ff
Binary files /dev/null and b/flink-core/src/test/resources/pojo-serializer-with-non-registered-subclass-1.13/serializer-snapshot differ
diff --git a/flink-core/src/test/resources/pojo-serializer-with-non-registered-subclass-1.13/test-data b/flink-core/src/test/resources/pojo-serializer-with-non-registered-subclass-1.13/test-data
new file mode 100644
index 0000000..10ca450
Binary files /dev/null and b/flink-core/src/test/resources/pojo-serializer-with-non-registered-subclass-1.13/test-data differ
diff --git a/flink-core/src/test/resources/row-serializer-1.13/serializer-snapshot b/flink-core/src/test/resources/row-serializer-1.13/serializer-snapshot
new file mode 100644
index 0000000..13445d3
Binary files /dev/null and b/flink-core/src/test/resources/row-serializer-1.13/serializer-snapshot differ
diff --git a/flink-core/src/test/resources/row-serializer-1.13/test-data b/flink-core/src/test/resources/row-serializer-1.13/test-data
new file mode 100644
index 0000000..a734bd4
Binary files /dev/null and b/flink-core/src/test/resources/row-serializer-1.13/test-data differ
diff --git a/flink-core/src/test/resources/short-primitive-array-serializer-1.13/serializer-snapshot b/flink-core/src/test/resources/short-primitive-array-serializer-1.13/serializer-snapshot
new file mode 100644
index 0000000..5d2d0fc
Binary files /dev/null and b/flink-core/src/test/resources/short-primitive-array-serializer-1.13/serializer-snapshot differ
diff --git a/flink-core/src/test/resources/short-primitive-array-serializer-1.13/test-data b/flink-core/src/test/resources/short-primitive-array-serializer-1.13/test-data
new file mode 100644
index 0000000..cc4337b
Binary files /dev/null and b/flink-core/src/test/resources/short-primitive-array-serializer-1.13/test-data differ
diff --git a/flink-core/src/test/resources/short-serializer-1.13/serializer-snapshot b/flink-core/src/test/resources/short-serializer-1.13/serializer-snapshot
new file mode 100644
index 0000000..0960c9b
Binary files /dev/null and b/flink-core/src/test/resources/short-serializer-1.13/serializer-snapshot differ
diff --git a/flink-core/src/test/resources/short-serializer-1.13/test-data b/flink-core/src/test/resources/short-serializer-1.13/test-data
new file mode 100644
index 0000000..aa9c341
Binary files /dev/null and b/flink-core/src/test/resources/short-serializer-1.13/test-data differ
diff --git a/flink-core/src/test/resources/short-value-serializer-1.13/serializer-snapshot b/flink-core/src/test/resources/short-value-serializer-1.13/serializer-snapshot
new file mode 100644
index 0000000..c7808f5
Binary files /dev/null and b/flink-core/src/test/resources/short-value-serializer-1.13/serializer-snapshot differ
diff --git a/flink-core/src/test/resources/short-value-serializer-1.13/test-data b/flink-core/src/test/resources/short-value-serializer-1.13/test-data
new file mode 100644
index 0000000..aa9c341
Binary files /dev/null and b/flink-core/src/test/resources/short-value-serializer-1.13/test-data differ
diff --git a/flink-core/src/test/resources/sql-date-serializer-1.13/serializer-snapshot b/flink-core/src/test/resources/sql-date-serializer-1.13/serializer-snapshot
new file mode 100644
index 0000000..1042bba
Binary files /dev/null and b/flink-core/src/test/resources/sql-date-serializer-1.13/serializer-snapshot differ
diff --git a/flink-core/src/test/resources/sql-date-serializer-1.13/test-data b/flink-core/src/test/resources/sql-date-serializer-1.13/test-data
new file mode 100644
index 0000000..1faf9a0
Binary files /dev/null and b/flink-core/src/test/resources/sql-date-serializer-1.13/test-data differ
diff --git a/flink-core/src/test/resources/sql-time-serializer-1.13/serializer-snapshot b/flink-core/src/test/resources/sql-time-serializer-1.13/serializer-snapshot
new file mode 100644
index 0000000..039309b
Binary files /dev/null and b/flink-core/src/test/resources/sql-time-serializer-1.13/serializer-snapshot differ
diff --git a/flink-core/src/test/resources/sql-time-serializer-1.13/test-data b/flink-core/src/test/resources/sql-time-serializer-1.13/test-data
new file mode 100644
index 0000000..1faf9a0
Binary files /dev/null and b/flink-core/src/test/resources/sql-time-serializer-1.13/test-data differ
diff --git a/flink-core/src/test/resources/sql-timestamp-serializer-1.13/serializer-snapshot b/flink-core/src/test/resources/sql-timestamp-serializer-1.13/serializer-snapshot
new file mode 100644
index 0000000..295fa6e
Binary files /dev/null and b/flink-core/src/test/resources/sql-timestamp-serializer-1.13/serializer-snapshot differ
diff --git a/flink-core/src/test/resources/sql-timestamp-serializer-1.13/test-data b/flink-core/src/test/resources/sql-timestamp-serializer-1.13/test-data
new file mode 100644
index 0000000..929596b
Binary files /dev/null and b/flink-core/src/test/resources/sql-timestamp-serializer-1.13/test-data differ
diff --git a/flink-core/src/test/resources/string-array-serializer-1.13/serializer-snapshot b/flink-core/src/test/resources/string-array-serializer-1.13/serializer-snapshot
new file mode 100644
index 0000000..acc4e9d
Binary files /dev/null and b/flink-core/src/test/resources/string-array-serializer-1.13/serializer-snapshot differ
diff --git a/flink-core/src/test/resources/string-array-serializer-1.13/test-data b/flink-core/src/test/resources/string-array-serializer-1.13/test-data
new file mode 100644
index 0000000..f1a5645
Binary files /dev/null and b/flink-core/src/test/resources/string-array-serializer-1.13/test-data differ
diff --git a/flink-core/src/test/resources/string-serializer-1.13/serializer-snapshot b/flink-core/src/test/resources/string-serializer-1.13/serializer-snapshot
new file mode 100644
index 0000000..f796fdd
Binary files /dev/null and b/flink-core/src/test/resources/string-serializer-1.13/serializer-snapshot differ
diff --git a/flink-core/src/test/resources/string-serializer-1.13/test-data b/flink-core/src/test/resources/string-serializer-1.13/test-data
new file mode 100644
index 0000000..67ad74d
--- /dev/null
+++ b/flink-core/src/test/resources/string-serializer-1.13/test-data
@@ -0,0 +1 @@
+%123456789012345678901234567890123456
\ No newline at end of file
diff --git a/flink-core/src/test/resources/string-value-serializer-1.13/serializer-snapshot b/flink-core/src/test/resources/string-value-serializer-1.13/serializer-snapshot
new file mode 100644
index 0000000..c7055ea
Binary files /dev/null and b/flink-core/src/test/resources/string-value-serializer-1.13/serializer-snapshot differ
diff --git a/flink-core/src/test/resources/string-value-serializer-1.13/test-data b/flink-core/src/test/resources/string-value-serializer-1.13/test-data
new file mode 100644
index 0000000..9233b5a
--- /dev/null
+++ b/flink-core/src/test/resources/string-value-serializer-1.13/test-data
@@ -0,0 +1 @@
+$123456789012345678901234567890123456
\ No newline at end of file
diff --git a/flink-core/src/test/resources/tuple-serializer-1.13/serializer-snapshot b/flink-core/src/test/resources/tuple-serializer-1.13/serializer-snapshot
new file mode 100644
index 0000000..ac31cfe
Binary files /dev/null and b/flink-core/src/test/resources/tuple-serializer-1.13/serializer-snapshot differ
diff --git a/flink-core/src/test/resources/tuple-serializer-1.13/test-data b/flink-core/src/test/resources/tuple-serializer-1.13/test-data
new file mode 100644
index 0000000..808ccbc
Binary files /dev/null and b/flink-core/src/test/resources/tuple-serializer-1.13/test-data differ
diff --git a/flink-core/src/test/resources/value-serializer-1.13/serializer-snapshot b/flink-core/src/test/resources/value-serializer-1.13/serializer-snapshot
new file mode 100644
index 0000000..26ee2df
Binary files /dev/null and b/flink-core/src/test/resources/value-serializer-1.13/serializer-snapshot differ
diff --git a/flink-core/src/test/resources/value-serializer-1.13/test-data b/flink-core/src/test/resources/value-serializer-1.13/test-data
new file mode 100644
index 0000000..c1e4937
Binary files /dev/null and b/flink-core/src/test/resources/value-serializer-1.13/test-data differ
diff --git a/flink-formats/flink-avro/src/test/resources/generic-avro-serializer-1.13/serializer-snapshot b/flink-formats/flink-avro/src/test/resources/generic-avro-serializer-1.13/serializer-snapshot
new file mode 100644
index 0000000..7bd4d72
Binary files /dev/null and b/flink-formats/flink-avro/src/test/resources/generic-avro-serializer-1.13/serializer-snapshot differ
diff --git a/flink-formats/flink-avro/src/test/resources/generic-avro-serializer-1.13/test-data b/flink-formats/flink-avro/src/test/resources/generic-avro-serializer-1.13/test-data
new file mode 100644
index 0000000..5a7679a
Binary files /dev/null and b/flink-formats/flink-avro/src/test/resources/generic-avro-serializer-1.13/test-data differ
diff --git a/flink-formats/flink-avro/src/test/resources/specific-avro-serializer-1.13/serializer-snapshot b/flink-formats/flink-avro/src/test/resources/specific-avro-serializer-1.13/serializer-snapshot
new file mode 100644
index 0000000..d67dffc
Binary files /dev/null and b/flink-formats/flink-avro/src/test/resources/specific-avro-serializer-1.13/serializer-snapshot differ
diff --git a/flink-formats/flink-avro/src/test/resources/specific-avro-serializer-1.13/test-data b/flink-formats/flink-avro/src/test/resources/specific-avro-serializer-1.13/test-data
new file mode 100644
index 0000000..5a7679a
Binary files /dev/null and b/flink-formats/flink-avro/src/test/resources/specific-avro-serializer-1.13/test-data differ
diff --git a/flink-fs-tests/src/test/java/org/apache/flink/hdfstests/ContinuousFileProcessingMigrationTest.java b/flink-fs-tests/src/test/java/org/apache/flink/hdfstests/ContinuousFileProcessingMigrationTest.java
index e669bc8..2b76ea8 100644
--- a/flink-fs-tests/src/test/java/org/apache/flink/hdfstests/ContinuousFileProcessingMigrationTest.java
+++ b/flink-fs-tests/src/test/java/org/apache/flink/hdfstests/ContinuousFileProcessingMigrationTest.java
@@ -82,7 +82,8 @@ public class ContinuousFileProcessingMigrationTest {
Tuple2.of(MigrationVersion.v1_9, 1567499868000L),
Tuple2.of(MigrationVersion.v1_10, 1594559333000L),
Tuple2.of(MigrationVersion.v1_11, 1594561663000L),
- Tuple2.of(MigrationVersion.v1_12, 1613720148000L));
+ Tuple2.of(MigrationVersion.v1_12, 1613720148000L),
+ Tuple2.of(MigrationVersion.v1_13, 1627550216000L));
}
/**
diff --git a/flink-fs-tests/src/test/resources/monitoring-function-migration-test-1627550216000-flink1.13-snapshot b/flink-fs-tests/src/test/resources/monitoring-function-migration-test-1627550216000-flink1.13-snapshot
new file mode 100644
index 0000000..c0497c3
Binary files /dev/null and b/flink-fs-tests/src/test/resources/monitoring-function-migration-test-1627550216000-flink1.13-snapshot differ
diff --git a/flink-fs-tests/src/test/resources/reader-migration-test-flink1.13-snapshot b/flink-fs-tests/src/test/resources/reader-migration-test-flink1.13-snapshot
new file mode 100644
index 0000000..8d3eced
Binary files /dev/null and b/flink-fs-tests/src/test/resources/reader-migration-test-flink1.13-snapshot differ
diff --git a/flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/operator/CEPMigrationTest.java b/flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/operator/CEPMigrationTest.java
index 6d817b2..f7aba18 100644
--- a/flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/operator/CEPMigrationTest.java
+++ b/flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/operator/CEPMigrationTest.java
@@ -79,7 +79,8 @@ public class CEPMigrationTest {
MigrationVersion.v1_9,
MigrationVersion.v1_10,
MigrationVersion.v1_11,
- MigrationVersion.v1_12);
+ MigrationVersion.v1_12,
+ MigrationVersion.v1_13);
}
public CEPMigrationTest(MigrationVersion migrateVersion) {
diff --git a/flink-libraries/flink-cep/src/test/resources/cep-migration-after-branching-flink1.13-snapshot b/flink-libraries/flink-cep/src/test/resources/cep-migration-after-branching-flink1.13-snapshot
new file mode 100644
index 0000000..1565922
Binary files /dev/null and b/flink-libraries/flink-cep/src/test/resources/cep-migration-after-branching-flink1.13-snapshot differ
diff --git a/flink-libraries/flink-cep/src/test/resources/cep-migration-conditions-flink1.13-snapshot b/flink-libraries/flink-cep/src/test/resources/cep-migration-conditions-flink1.13-snapshot
new file mode 100644
index 0000000..caf8c51
Binary files /dev/null and b/flink-libraries/flink-cep/src/test/resources/cep-migration-conditions-flink1.13-snapshot differ
diff --git a/flink-libraries/flink-cep/src/test/resources/cep-migration-single-pattern-afterwards-flink1.13-snapshot b/flink-libraries/flink-cep/src/test/resources/cep-migration-single-pattern-afterwards-flink1.13-snapshot
new file mode 100644
index 0000000..ee7bb33
Binary files /dev/null and b/flink-libraries/flink-cep/src/test/resources/cep-migration-single-pattern-afterwards-flink1.13-snapshot differ
diff --git a/flink-libraries/flink-cep/src/test/resources/cep-migration-starting-new-pattern-flink1.13-snapshot b/flink-libraries/flink-cep/src/test/resources/cep-migration-starting-new-pattern-flink1.13-snapshot
new file mode 100644
index 0000000..cebbfee
Binary files /dev/null and b/flink-libraries/flink-cep/src/test/resources/cep-migration-starting-new-pattern-flink1.13-snapshot differ
diff --git a/flink-libraries/flink-cep/src/test/resources/dewey-number-serializer-1.13/serializer-snapshot b/flink-libraries/flink-cep/src/test/resources/dewey-number-serializer-1.13/serializer-snapshot
new file mode 100644
index 0000000..338c628
Binary files /dev/null and b/flink-libraries/flink-cep/src/test/resources/dewey-number-serializer-1.13/serializer-snapshot differ
diff --git a/flink-libraries/flink-cep/src/test/resources/dewey-number-serializer-1.13/test-data b/flink-libraries/flink-cep/src/test/resources/dewey-number-serializer-1.13/test-data
new file mode 100644
index 0000000..f870518
Binary files /dev/null and b/flink-libraries/flink-cep/src/test/resources/dewey-number-serializer-1.13/test-data differ
diff --git a/flink-libraries/flink-cep/src/test/resources/event-id-serializer-1.13/serializer-snapshot b/flink-libraries/flink-cep/src/test/resources/event-id-serializer-1.13/serializer-snapshot
new file mode 100644
index 0000000..40dcf61
Binary files /dev/null and b/flink-libraries/flink-cep/src/test/resources/event-id-serializer-1.13/serializer-snapshot differ
diff --git a/flink-libraries/flink-cep/src/test/resources/event-id-serializer-1.13/test-data b/flink-libraries/flink-cep/src/test/resources/event-id-serializer-1.13/test-data
new file mode 100644
index 0000000..146a1fc
Binary files /dev/null and b/flink-libraries/flink-cep/src/test/resources/event-id-serializer-1.13/test-data differ
diff --git a/flink-libraries/flink-cep/src/test/resources/lockable-type-serializer-1.13/serializer-snapshot b/flink-libraries/flink-cep/src/test/resources/lockable-type-serializer-1.13/serializer-snapshot
new file mode 100644
index 0000000..1a984b6
Binary files /dev/null and b/flink-libraries/flink-cep/src/test/resources/lockable-type-serializer-1.13/serializer-snapshot differ
diff --git a/flink-libraries/flink-cep/src/test/resources/lockable-type-serializer-1.13/test-data b/flink-libraries/flink-cep/src/test/resources/lockable-type-serializer-1.13/test-data
new file mode 100644
index 0000000..893957a
Binary files /dev/null and b/flink-libraries/flink-cep/src/test/resources/lockable-type-serializer-1.13/test-data differ
diff --git a/flink-libraries/flink-cep/src/test/resources/nfa-state-serializer-1.13/serializer-snapshot b/flink-libraries/flink-cep/src/test/resources/nfa-state-serializer-1.13/serializer-snapshot
new file mode 100644
index 0000000..b0d1ccf
Binary files /dev/null and b/flink-libraries/flink-cep/src/test/resources/nfa-state-serializer-1.13/serializer-snapshot differ
diff --git a/flink-libraries/flink-cep/src/test/resources/nfa-state-serializer-1.13/test-data b/flink-libraries/flink-cep/src/test/resources/nfa-state-serializer-1.13/test-data
new file mode 100644
index 0000000..1b1cb4d
Binary files /dev/null and b/flink-libraries/flink-cep/src/test/resources/nfa-state-serializer-1.13/test-data differ
diff --git a/flink-libraries/flink-cep/src/test/resources/node-id-serializer-1.13/serializer-snapshot b/flink-libraries/flink-cep/src/test/resources/node-id-serializer-1.13/serializer-snapshot
new file mode 100644
index 0000000..a63858d
Binary files /dev/null and b/flink-libraries/flink-cep/src/test/resources/node-id-serializer-1.13/serializer-snapshot differ
diff --git a/flink-libraries/flink-cep/src/test/resources/node-id-serializer-1.13/test-data b/flink-libraries/flink-cep/src/test/resources/node-id-serializer-1.13/test-data
new file mode 100644
index 0000000..0d33392
Binary files /dev/null and b/flink-libraries/flink-cep/src/test/resources/node-id-serializer-1.13/test-data differ
diff --git a/flink-libraries/flink-cep/src/test/resources/shared-buffer-edge-serializer-1.13/serializer-snapshot b/flink-libraries/flink-cep/src/test/resources/shared-buffer-edge-serializer-1.13/serializer-snapshot
new file mode 100644
index 0000000..bd1cd93
Binary files /dev/null and b/flink-libraries/flink-cep/src/test/resources/shared-buffer-edge-serializer-1.13/serializer-snapshot differ
diff --git a/flink-libraries/flink-cep/src/test/resources/shared-buffer-edge-serializer-1.13/test-data b/flink-libraries/flink-cep/src/test/resources/shared-buffer-edge-serializer-1.13/test-data
new file mode 100644
index 0000000..8746c6f
Binary files /dev/null and b/flink-libraries/flink-cep/src/test/resources/shared-buffer-edge-serializer-1.13/test-data differ
diff --git a/flink-libraries/flink-gelly-examples/src/test/resources/long-value-with-proper-hash-code-serializer-1.13/serializer-snapshot b/flink-libraries/flink-gelly-examples/src/test/resources/long-value-with-proper-hash-code-serializer-1.13/serializer-snapshot
new file mode 100644
index 0000000..a13cc13
Binary files /dev/null and b/flink-libraries/flink-gelly-examples/src/test/resources/long-value-with-proper-hash-code-serializer-1.13/serializer-snapshot differ
diff --git a/flink-libraries/flink-gelly-examples/src/test/resources/long-value-with-proper-hash-code-serializer-1.13/test-data b/flink-libraries/flink-gelly-examples/src/test/resources/long-value-with-proper-hash-code-serializer-1.13/test-data
new file mode 100644
index 0000000..beaca12
Binary files /dev/null and b/flink-libraries/flink-gelly-examples/src/test/resources/long-value-with-proper-hash-code-serializer-1.13/test-data differ
diff --git a/flink-libraries/flink-gelly/src/test/resources/byte-value-array-serializer-1.13/serializer-snapshot b/flink-libraries/flink-gelly/src/test/resources/byte-value-array-serializer-1.13/serializer-snapshot
new file mode 100644
index 0000000..9fe3b55
Binary files /dev/null and b/flink-libraries/flink-gelly/src/test/resources/byte-value-array-serializer-1.13/serializer-snapshot differ
diff --git a/flink-libraries/flink-gelly/src/test/resources/byte-value-array-serializer-1.13/test-data b/flink-libraries/flink-gelly/src/test/resources/byte-value-array-serializer-1.13/test-data
new file mode 100644
index 0000000..7931995
Binary files /dev/null and b/flink-libraries/flink-gelly/src/test/resources/byte-value-array-serializer-1.13/test-data differ
diff --git a/flink-libraries/flink-gelly/src/test/resources/char-value-array-serializer-1.13/serializer-snapshot b/flink-libraries/flink-gelly/src/test/resources/char-value-array-serializer-1.13/serializer-snapshot
new file mode 100644
index 0000000..600c0c7
Binary files /dev/null and b/flink-libraries/flink-gelly/src/test/resources/char-value-array-serializer-1.13/serializer-snapshot differ
diff --git a/flink-libraries/flink-gelly/src/test/resources/char-value-array-serializer-1.13/test-data b/flink-libraries/flink-gelly/src/test/resources/char-value-array-serializer-1.13/test-data
new file mode 100644
index 0000000..14a702b
Binary files /dev/null and b/flink-libraries/flink-gelly/src/test/resources/char-value-array-serializer-1.13/test-data differ
diff --git a/flink-libraries/flink-gelly/src/test/resources/double-value-array-serializer-1.13/serializer-snapshot b/flink-libraries/flink-gelly/src/test/resources/double-value-array-serializer-1.13/serializer-snapshot
new file mode 100644
index 0000000..820d582
Binary files /dev/null and b/flink-libraries/flink-gelly/src/test/resources/double-value-array-serializer-1.13/serializer-snapshot differ
diff --git a/flink-libraries/flink-gelly/src/test/resources/double-value-array-serializer-1.13/test-data b/flink-libraries/flink-gelly/src/test/resources/double-value-array-serializer-1.13/test-data
new file mode 100644
index 0000000..3471def
Binary files /dev/null and b/flink-libraries/flink-gelly/src/test/resources/double-value-array-serializer-1.13/test-data differ
diff --git a/flink-libraries/flink-gelly/src/test/resources/float-value-array-serializer-1.13/serializer-snapshot b/flink-libraries/flink-gelly/src/test/resources/float-value-array-serializer-1.13/serializer-snapshot
new file mode 100644
index 0000000..ba5bfc7
Binary files /dev/null and b/flink-libraries/flink-gelly/src/test/resources/float-value-array-serializer-1.13/serializer-snapshot differ
diff --git a/flink-libraries/flink-gelly/src/test/resources/float-value-array-serializer-1.13/test-data b/flink-libraries/flink-gelly/src/test/resources/float-value-array-serializer-1.13/test-data
new file mode 100644
index 0000000..fd12df0
Binary files /dev/null and b/flink-libraries/flink-gelly/src/test/resources/float-value-array-serializer-1.13/test-data differ
diff --git a/flink-libraries/flink-gelly/src/test/resources/int-value-array-serializer-1.13/serializer-snapshot b/flink-libraries/flink-gelly/src/test/resources/int-value-array-serializer-1.13/serializer-snapshot
new file mode 100644
index 0000000..17dcd43
Binary files /dev/null and b/flink-libraries/flink-gelly/src/test/resources/int-value-array-serializer-1.13/serializer-snapshot differ
diff --git a/flink-libraries/flink-gelly/src/test/resources/int-value-array-serializer-1.13/test-data b/flink-libraries/flink-gelly/src/test/resources/int-value-array-serializer-1.13/test-data
new file mode 100644
index 0000000..88151a6
Binary files /dev/null and b/flink-libraries/flink-gelly/src/test/resources/int-value-array-serializer-1.13/test-data differ
diff --git a/flink-libraries/flink-gelly/src/test/resources/long-value-array-serializer-1.13/serializer-snapshot b/flink-libraries/flink-gelly/src/test/resources/long-value-array-serializer-1.13/serializer-snapshot
new file mode 100644
index 0000000..be36756
Binary files /dev/null and b/flink-libraries/flink-gelly/src/test/resources/long-value-array-serializer-1.13/serializer-snapshot differ
diff --git a/flink-libraries/flink-gelly/src/test/resources/long-value-array-serializer-1.13/test-data b/flink-libraries/flink-gelly/src/test/resources/long-value-array-serializer-1.13/test-data
new file mode 100644
index 0000000..9e8d516
Binary files /dev/null and b/flink-libraries/flink-gelly/src/test/resources/long-value-array-serializer-1.13/test-data differ
diff --git a/flink-libraries/flink-gelly/src/test/resources/null-value-array-serializer-1.13/serializer-snapshot b/flink-libraries/flink-gelly/src/test/resources/null-value-array-serializer-1.13/serializer-snapshot
new file mode 100644
index 0000000..91c0992
Binary files /dev/null and b/flink-libraries/flink-gelly/src/test/resources/null-value-array-serializer-1.13/serializer-snapshot differ
diff --git a/flink-libraries/flink-gelly/src/test/resources/null-value-array-serializer-1.13/test-data b/flink-libraries/flink-gelly/src/test/resources/null-value-array-serializer-1.13/test-data
new file mode 100644
index 0000000..b6a8ef3
Binary files /dev/null and b/flink-libraries/flink-gelly/src/test/resources/null-value-array-serializer-1.13/test-data differ
diff --git a/flink-libraries/flink-gelly/src/test/resources/short-value-array-serializer-1.13/serializer-snapshot b/flink-libraries/flink-gelly/src/test/resources/short-value-array-serializer-1.13/serializer-snapshot
new file mode 100644
index 0000000..01f646a
Binary files /dev/null and b/flink-libraries/flink-gelly/src/test/resources/short-value-array-serializer-1.13/serializer-snapshot differ
diff --git a/flink-libraries/flink-gelly/src/test/resources/short-value-array-serializer-1.13/test-data b/flink-libraries/flink-gelly/src/test/resources/short-value-array-serializer-1.13/test-data
new file mode 100644
index 0000000..ed5ae2b
Binary files /dev/null and b/flink-libraries/flink-gelly/src/test/resources/short-value-array-serializer-1.13/test-data differ
diff --git a/flink-libraries/flink-gelly/src/test/resources/string-value-array-serializer-1.13/serializer-snapshot b/flink-libraries/flink-gelly/src/test/resources/string-value-array-serializer-1.13/serializer-snapshot
new file mode 100644
index 0000000..2d09e95
Binary files /dev/null and b/flink-libraries/flink-gelly/src/test/resources/string-value-array-serializer-1.13/serializer-snapshot differ
diff --git a/flink-libraries/flink-gelly/src/test/resources/string-value-array-serializer-1.13/test-data b/flink-libraries/flink-gelly/src/test/resources/string-value-array-serializer-1.13/test-data
new file mode 100644
index 0000000..40500f3
Binary files /dev/null and b/flink-libraries/flink-gelly/src/test/resources/string-value-array-serializer-1.13/test-data differ
diff --git a/flink-runtime/src/test/resources/arraylist-serializer-1.13/serializer-snapshot b/flink-runtime/src/test/resources/arraylist-serializer-1.13/serializer-snapshot
new file mode 100644
index 0000000..2bc2cfe
Binary files /dev/null and b/flink-runtime/src/test/resources/arraylist-serializer-1.13/serializer-snapshot differ
diff --git a/flink-runtime/src/test/resources/arraylist-serializer-1.13/test-data b/flink-runtime/src/test/resources/arraylist-serializer-1.13/test-data
new file mode 100644
index 0000000..ac79859
Binary files /dev/null and b/flink-runtime/src/test/resources/arraylist-serializer-1.13/test-data differ
diff --git a/flink-runtime/src/test/resources/java-serializer-1.13/serializer-snapshot b/flink-runtime/src/test/resources/java-serializer-1.13/serializer-snapshot
new file mode 100644
index 0000000..db1abe9
Binary files /dev/null and b/flink-runtime/src/test/resources/java-serializer-1.13/serializer-snapshot differ
diff --git a/flink-runtime/src/test/resources/java-serializer-1.13/test-data b/flink-runtime/src/test/resources/java-serializer-1.13/test-data
new file mode 100644
index 0000000..22a3c76
Binary files /dev/null and b/flink-runtime/src/test/resources/java-serializer-1.13/test-data differ
diff --git a/flink-runtime/src/test/resources/ttl-serializer-1.13/serializer-snapshot b/flink-runtime/src/test/resources/ttl-serializer-1.13/serializer-snapshot
new file mode 100644
index 0000000..7668b61
Binary files /dev/null and b/flink-runtime/src/test/resources/ttl-serializer-1.13/serializer-snapshot differ
diff --git a/flink-runtime/src/test/resources/ttl-serializer-1.13/test-data b/flink-runtime/src/test/resources/ttl-serializer-1.13/test-data
new file mode 100644
index 0000000..5596986
Binary files /dev/null and b/flink-runtime/src/test/resources/ttl-serializer-1.13/test-data differ
diff --git a/flink-runtime/src/test/resources/void-namespace-serializer-1.13/serializer-snapshot b/flink-runtime/src/test/resources/void-namespace-serializer-1.13/serializer-snapshot
new file mode 100644
index 0000000..9df815a
Binary files /dev/null and b/flink-runtime/src/test/resources/void-namespace-serializer-1.13/serializer-snapshot differ
diff --git a/flink-runtime/src/test/resources/void-namespace-serializer-1.13/test-data b/flink-runtime/src/test/resources/void-namespace-serializer-1.13/test-data
new file mode 100644
index 0000000..f76dd23
Binary files /dev/null and b/flink-runtime/src/test/resources/void-namespace-serializer-1.13/test-data differ
diff --git a/flink-scala/src/test/resources/scala-case-class-serializer-1.13/serializer-snapshot b/flink-scala/src/test/resources/scala-case-class-serializer-1.13/serializer-snapshot
new file mode 100644
index 0000000..b50a73e
Binary files /dev/null and b/flink-scala/src/test/resources/scala-case-class-serializer-1.13/serializer-snapshot differ
diff --git a/flink-scala/src/test/resources/scala-case-class-serializer-1.13/test-data b/flink-scala/src/test/resources/scala-case-class-serializer-1.13/test-data
new file mode 100644
index 0000000..ddb6ef5
Binary files /dev/null and b/flink-scala/src/test/resources/scala-case-class-serializer-1.13/test-data differ
diff --git a/flink-scala/src/test/resources/scala-either-serializer-1.13/serializer-snapshot b/flink-scala/src/test/resources/scala-either-serializer-1.13/serializer-snapshot
new file mode 100644
index 0000000..2258df5
Binary files /dev/null and b/flink-scala/src/test/resources/scala-either-serializer-1.13/serializer-snapshot differ
diff --git a/flink-scala/src/test/resources/scala-either-serializer-1.13/test-data b/flink-scala/src/test/resources/scala-either-serializer-1.13/test-data
new file mode 100644
index 0000000..70cd7bf
Binary files /dev/null and b/flink-scala/src/test/resources/scala-either-serializer-1.13/test-data differ
diff --git a/flink-scala/src/test/resources/scala-enum-serializer-1.13/serializer-snapshot b/flink-scala/src/test/resources/scala-enum-serializer-1.13/serializer-snapshot
new file mode 100644
index 0000000..4a467f2
Binary files /dev/null and b/flink-scala/src/test/resources/scala-enum-serializer-1.13/serializer-snapshot differ
diff --git a/flink-scala/src/test/resources/scala-enum-serializer-1.13/test-data b/flink-scala/src/test/resources/scala-enum-serializer-1.13/test-data
new file mode 100644
index 0000000..593f470
Binary files /dev/null and b/flink-scala/src/test/resources/scala-enum-serializer-1.13/test-data differ
diff --git a/flink-scala/src/test/resources/scala-option-serializer-1.13/serializer-snapshot b/flink-scala/src/test/resources/scala-option-serializer-1.13/serializer-snapshot
new file mode 100644
index 0000000..91808c1
Binary files /dev/null and b/flink-scala/src/test/resources/scala-option-serializer-1.13/serializer-snapshot differ
diff --git a/flink-scala/src/test/resources/scala-option-serializer-1.13/test-data b/flink-scala/src/test/resources/scala-option-serializer-1.13/test-data
new file mode 100644
index 0000000..f76dd23
Binary files /dev/null and b/flink-scala/src/test/resources/scala-option-serializer-1.13/test-data differ
diff --git a/flink-scala/src/test/resources/scala-try-serializer-1.13/serializer-snapshot b/flink-scala/src/test/resources/scala-try-serializer-1.13/serializer-snapshot
new file mode 100644
index 0000000..f5ad2ec
Binary files /dev/null and b/flink-scala/src/test/resources/scala-try-serializer-1.13/serializer-snapshot differ
diff --git a/flink-scala/src/test/resources/scala-try-serializer-1.13/test-data b/flink-scala/src/test/resources/scala-try-serializer-1.13/test-data
new file mode 100644
index 0000000..f1df3e9
Binary files /dev/null and b/flink-scala/src/test/resources/scala-try-serializer-1.13/test-data differ
diff --git a/flink-scala/src/test/resources/traversable-serializer-bitset-1.13/serializer-snapshot b/flink-scala/src/test/resources/traversable-serializer-bitset-1.13/serializer-snapshot
new file mode 100644
index 0000000..03d7937
Binary files /dev/null and b/flink-scala/src/test/resources/traversable-serializer-bitset-1.13/serializer-snapshot differ
diff --git a/flink-scala/src/test/resources/traversable-serializer-bitset-1.13/test-data b/flink-scala/src/test/resources/traversable-serializer-bitset-1.13/test-data
new file mode 100644
index 0000000..5eb5107
Binary files /dev/null and b/flink-scala/src/test/resources/traversable-serializer-bitset-1.13/test-data differ
diff --git a/flink-scala/src/test/resources/traversable-serializer-indexedseq-1.13/serializer-snapshot b/flink-scala/src/test/resources/traversable-serializer-indexedseq-1.13/serializer-snapshot
new file mode 100644
index 0000000..4cd4798
Binary files /dev/null and b/flink-scala/src/test/resources/traversable-serializer-indexedseq-1.13/serializer-snapshot differ
diff --git a/flink-scala/src/test/resources/traversable-serializer-indexedseq-1.13/test-data b/flink-scala/src/test/resources/traversable-serializer-indexedseq-1.13/test-data
new file mode 100644
index 0000000..ca6108c
Binary files /dev/null and b/flink-scala/src/test/resources/traversable-serializer-indexedseq-1.13/test-data differ
diff --git a/flink-scala/src/test/resources/traversable-serializer-linearseq-1.13/serializer-snapshot b/flink-scala/src/test/resources/traversable-serializer-linearseq-1.13/serializer-snapshot
new file mode 100644
index 0000000..290d949
Binary files /dev/null and b/flink-scala/src/test/resources/traversable-serializer-linearseq-1.13/serializer-snapshot differ
diff --git a/flink-scala/src/test/resources/traversable-serializer-linearseq-1.13/test-data b/flink-scala/src/test/resources/traversable-serializer-linearseq-1.13/test-data
new file mode 100644
index 0000000..3b0d0b0
Binary files /dev/null and b/flink-scala/src/test/resources/traversable-serializer-linearseq-1.13/test-data differ
diff --git a/flink-scala/src/test/resources/traversable-serializer-map-1.13/serializer-snapshot b/flink-scala/src/test/resources/traversable-serializer-map-1.13/serializer-snapshot
new file mode 100644
index 0000000..b23cb07
Binary files /dev/null and b/flink-scala/src/test/resources/traversable-serializer-map-1.13/serializer-snapshot differ
diff --git a/flink-scala/src/test/resources/traversable-serializer-map-1.13/test-data b/flink-scala/src/test/resources/traversable-serializer-map-1.13/test-data
new file mode 100644
index 0000000..f209ff5
Binary files /dev/null and b/flink-scala/src/test/resources/traversable-serializer-map-1.13/test-data differ
diff --git a/flink-scala/src/test/resources/traversable-serializer-mutable-list-1.13/serializer-snapshot b/flink-scala/src/test/resources/traversable-serializer-mutable-list-1.13/serializer-snapshot
new file mode 100644
index 0000000..cec3314
Binary files /dev/null and b/flink-scala/src/test/resources/traversable-serializer-mutable-list-1.13/serializer-snapshot differ
diff --git a/flink-scala/src/test/resources/traversable-serializer-mutable-list-1.13/test-data b/flink-scala/src/test/resources/traversable-serializer-mutable-list-1.13/test-data
new file mode 100644
index 0000000..ca6108c
Binary files /dev/null and b/flink-scala/src/test/resources/traversable-serializer-mutable-list-1.13/test-data differ
diff --git a/flink-scala/src/test/resources/traversable-serializer-seq-1.13/serializer-snapshot b/flink-scala/src/test/resources/traversable-serializer-seq-1.13/serializer-snapshot
new file mode 100644
index 0000000..bac0255
Binary files /dev/null and b/flink-scala/src/test/resources/traversable-serializer-seq-1.13/serializer-snapshot differ
diff --git a/flink-scala/src/test/resources/traversable-serializer-seq-1.13/test-data b/flink-scala/src/test/resources/traversable-serializer-seq-1.13/test-data
new file mode 100644
index 0000000..ca6108c
Binary files /dev/null and b/flink-scala/src/test/resources/traversable-serializer-seq-1.13/test-data differ
diff --git a/flink-scala/src/test/resources/traversable-serializer-set-1.13/serializer-snapshot b/flink-scala/src/test/resources/traversable-serializer-set-1.13/serializer-snapshot
new file mode 100644
index 0000000..d90d197
Binary files /dev/null and b/flink-scala/src/test/resources/traversable-serializer-set-1.13/serializer-snapshot differ
diff --git a/flink-scala/src/test/resources/traversable-serializer-set-1.13/test-data b/flink-scala/src/test/resources/traversable-serializer-set-1.13/test-data
new file mode 100644
index 0000000..3b0d0b0
Binary files /dev/null and b/flink-scala/src/test/resources/traversable-serializer-set-1.13/test-data differ
diff --git a/flink-scala/src/test/resources/traversable-serializer-with-case-class-1.13/serializer-snapshot b/flink-scala/src/test/resources/traversable-serializer-with-case-class-1.13/serializer-snapshot
new file mode 100644
index 0000000..25284ed
Binary files /dev/null and b/flink-scala/src/test/resources/traversable-serializer-with-case-class-1.13/serializer-snapshot differ
diff --git a/flink-scala/src/test/resources/traversable-serializer-with-case-class-1.13/test-data b/flink-scala/src/test/resources/traversable-serializer-with-case-class-1.13/test-data
new file mode 100644
index 0000000..7adaf00
Binary files /dev/null and b/flink-scala/src/test/resources/traversable-serializer-with-case-class-1.13/test-data differ
diff --git a/flink-scala/src/test/resources/traversable-serializer-with-pojo-1.13/serializer-snapshot b/flink-scala/src/test/resources/traversable-serializer-with-pojo-1.13/serializer-snapshot
new file mode 100644
index 0000000..55d4877
Binary files /dev/null and b/flink-scala/src/test/resources/traversable-serializer-with-pojo-1.13/serializer-snapshot differ
diff --git a/flink-scala/src/test/resources/traversable-serializer-with-pojo-1.13/test-data b/flink-scala/src/test/resources/traversable-serializer-with-pojo-1.13/test-data
new file mode 100644
index 0000000..ebc7236
Binary files /dev/null and b/flink-scala/src/test/resources/traversable-serializer-with-pojo-1.13/test-data differ
diff --git a/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperatorMigrationTest.java b/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperatorMigrationTest.java
index ae9f9e3..1b1293f 100644
--- a/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperatorMigrationTest.java
+++ b/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperatorMigrationTest.java
@@ -95,7 +95,8 @@ public class WindowOperatorMigrationTest {
MigrationVersion.v1_9,
MigrationVersion.v1_10,
MigrationVersion.v1_11,
- MigrationVersion.v1_12);
+ MigrationVersion.v1_12,
+ MigrationVersion.v1_13);
}
private static final TypeInformation<Tuple2<String, Integer>> STRING_INT_TUPLE =
diff --git a/flink-streaming-java/src/test/resources/buffer-entry-serializer-1.13/serializer-snapshot b/flink-streaming-java/src/test/resources/buffer-entry-serializer-1.13/serializer-snapshot
new file mode 100644
index 0000000..4026c41
Binary files /dev/null and b/flink-streaming-java/src/test/resources/buffer-entry-serializer-1.13/serializer-snapshot differ
diff --git a/flink-streaming-java/src/test/resources/buffer-entry-serializer-1.13/test-data b/flink-streaming-java/src/test/resources/buffer-entry-serializer-1.13/test-data
new file mode 100644
index 0000000..7072021
Binary files /dev/null and b/flink-streaming-java/src/test/resources/buffer-entry-serializer-1.13/test-data differ
diff --git a/flink-streaming-java/src/test/resources/global-window-serializer-1.13/serializer-snapshot b/flink-streaming-java/src/test/resources/global-window-serializer-1.13/serializer-snapshot
new file mode 100644
index 0000000..ac44c4c
Binary files /dev/null and b/flink-streaming-java/src/test/resources/global-window-serializer-1.13/serializer-snapshot differ
diff --git a/flink-streaming-java/src/test/resources/global-window-serializer-1.13/test-data b/flink-streaming-java/src/test/resources/global-window-serializer-1.13/test-data
new file mode 100644
index 0000000..f76dd23
Binary files /dev/null and b/flink-streaming-java/src/test/resources/global-window-serializer-1.13/test-data differ
diff --git a/flink-streaming-java/src/test/resources/stream-element-serializer-1.13/serializer-snapshot b/flink-streaming-java/src/test/resources/stream-element-serializer-1.13/serializer-snapshot
new file mode 100644
index 0000000..2a9a9ae
Binary files /dev/null and b/flink-streaming-java/src/test/resources/stream-element-serializer-1.13/serializer-snapshot differ
diff --git a/flink-streaming-java/src/test/resources/stream-element-serializer-1.13/test-data b/flink-streaming-java/src/test/resources/stream-element-serializer-1.13/test-data
new file mode 100644
index 0000000..3022a08
Binary files /dev/null and b/flink-streaming-java/src/test/resources/stream-element-serializer-1.13/test-data differ
diff --git a/flink-streaming-java/src/test/resources/time-window-serializer-1.13/serializer-snapshot b/flink-streaming-java/src/test/resources/time-window-serializer-1.13/serializer-snapshot
new file mode 100644
index 0000000..7d2b4b6
Binary files /dev/null and b/flink-streaming-java/src/test/resources/time-window-serializer-1.13/serializer-snapshot differ
diff --git a/flink-streaming-java/src/test/resources/time-window-serializer-1.13/test-data b/flink-streaming-java/src/test/resources/time-window-serializer-1.13/test-data
new file mode 100644
index 0000000..bd72696
Binary files /dev/null and b/flink-streaming-java/src/test/resources/time-window-serializer-1.13/test-data differ
diff --git a/flink-streaming-java/src/test/resources/timer-serializer-1.13/serializer-snapshot b/flink-streaming-java/src/test/resources/timer-serializer-1.13/serializer-snapshot
new file mode 100644
index 0000000..67e3a08
Binary files /dev/null and b/flink-streaming-java/src/test/resources/timer-serializer-1.13/serializer-snapshot differ
diff --git a/flink-streaming-java/src/test/resources/timer-serializer-1.13/test-data b/flink-streaming-java/src/test/resources/timer-serializer-1.13/test-data
new file mode 100644
index 0000000..5e9827d
Binary files /dev/null and b/flink-streaming-java/src/test/resources/timer-serializer-1.13/test-data differ
diff --git a/flink-streaming-java/src/test/resources/two-phase-commit-sink-state-serializer-1.13/serializer-snapshot b/flink-streaming-java/src/test/resources/two-phase-commit-sink-state-serializer-1.13/serializer-snapshot
new file mode 100644
index 0000000..18a2701
Binary files /dev/null and b/flink-streaming-java/src/test/resources/two-phase-commit-sink-state-serializer-1.13/serializer-snapshot differ
diff --git a/flink-streaming-java/src/test/resources/two-phase-commit-sink-state-serializer-1.13/test-data b/flink-streaming-java/src/test/resources/two-phase-commit-sink-state-serializer-1.13/test-data
new file mode 100644
index 0000000..6803ec8
Binary files /dev/null and b/flink-streaming-java/src/test/resources/two-phase-commit-sink-state-serializer-1.13/test-data differ
diff --git a/flink-streaming-java/src/test/resources/union-serializer-one-1.13/serializer-snapshot b/flink-streaming-java/src/test/resources/union-serializer-one-1.13/serializer-snapshot
new file mode 100644
index 0000000..8af8c71
Binary files /dev/null and b/flink-streaming-java/src/test/resources/union-serializer-one-1.13/serializer-snapshot differ
diff --git a/flink-streaming-java/src/test/resources/union-serializer-one-1.13/test-data b/flink-streaming-java/src/test/resources/union-serializer-one-1.13/test-data
new file mode 100644
index 0000000..9a2dda7
--- /dev/null
+++ b/flink-streaming-java/src/test/resources/union-serializer-one-1.13/test-data
@@ -0,0 +1 @@
+flink
\ No newline at end of file
diff --git a/flink-streaming-java/src/test/resources/union-serializer-two-1.13/serializer-snapshot b/flink-streaming-java/src/test/resources/union-serializer-two-1.13/serializer-snapshot
new file mode 100644
index 0000000..8af8c71
Binary files /dev/null and b/flink-streaming-java/src/test/resources/union-serializer-two-1.13/serializer-snapshot differ
diff --git a/flink-streaming-java/src/test/resources/union-serializer-two-1.13/test-data b/flink-streaming-java/src/test/resources/union-serializer-two-1.13/test-data
new file mode 100644
index 0000000..564b7c9
Binary files /dev/null and b/flink-streaming-java/src/test/resources/union-serializer-two-1.13/test-data differ
diff --git a/flink-streaming-java/src/test/resources/win-op-migration-test-apply-event-time-flink1.13-snapshot b/flink-streaming-java/src/test/resources/win-op-migration-test-apply-event-time-flink1.13-snapshot
new file mode 100644
index 0000000..9fa711b
Binary files /dev/null and b/flink-streaming-java/src/test/resources/win-op-migration-test-apply-event-time-flink1.13-snapshot differ
diff --git a/flink-streaming-java/src/test/resources/win-op-migration-test-apply-processing-time-flink1.13-snapshot b/flink-streaming-java/src/test/resources/win-op-migration-test-apply-processing-time-flink1.13-snapshot
new file mode 100644
index 0000000..e17fc02
Binary files /dev/null and b/flink-streaming-java/src/test/resources/win-op-migration-test-apply-processing-time-flink1.13-snapshot differ
diff --git a/flink-streaming-java/src/test/resources/win-op-migration-test-kryo-serialized-key-flink1.13-snapshot b/flink-streaming-java/src/test/resources/win-op-migration-test-kryo-serialized-key-flink1.13-snapshot
new file mode 100644
index 0000000..e64c96d
Binary files /dev/null and b/flink-streaming-java/src/test/resources/win-op-migration-test-kryo-serialized-key-flink1.13-snapshot differ
diff --git a/flink-streaming-java/src/test/resources/win-op-migration-test-reduce-event-time-flink1.13-snapshot b/flink-streaming-java/src/test/resources/win-op-migration-test-reduce-event-time-flink1.13-snapshot
new file mode 100644
index 0000000..0c5cfbb
Binary files /dev/null and b/flink-streaming-java/src/test/resources/win-op-migration-test-reduce-event-time-flink1.13-snapshot differ
diff --git a/flink-streaming-java/src/test/resources/win-op-migration-test-reduce-processing-time-flink1.13-snapshot b/flink-streaming-java/src/test/resources/win-op-migration-test-reduce-processing-time-flink1.13-snapshot
new file mode 100644
index 0000000..bc6dab9
Binary files /dev/null and b/flink-streaming-java/src/test/resources/win-op-migration-test-reduce-processing-time-flink1.13-snapshot differ
diff --git a/flink-streaming-java/src/test/resources/win-op-migration-test-session-with-stateful-trigger-flink1.13-snapshot b/flink-streaming-java/src/test/resources/win-op-migration-test-session-with-stateful-trigger-flink1.13-snapshot
new file mode 100644
index 0000000..384316b
Binary files /dev/null and b/flink-streaming-java/src/test/resources/win-op-migration-test-session-with-stateful-trigger-flink1.13-snapshot differ
diff --git a/flink-streaming-java/src/test/resources/win-op-migration-test-session-with-stateful-trigger-mint-flink1.13-snapshot b/flink-streaming-java/src/test/resources/win-op-migration-test-session-with-stateful-trigger-mint-flink1.13-snapshot
new file mode 100644
index 0000000..c7debe2
Binary files /dev/null and b/flink-streaming-java/src/test/resources/win-op-migration-test-session-with-stateful-trigger-mint-flink1.13-snapshot differ
diff --git a/flink-table/flink-table-planner/src/test/resources/list-view-serializer-1.13/serializer-snapshot b/flink-table/flink-table-planner/src/test/resources/list-view-serializer-1.13/serializer-snapshot
new file mode 100644
index 0000000..a890302
Binary files /dev/null and b/flink-table/flink-table-planner/src/test/resources/list-view-serializer-1.13/serializer-snapshot differ
diff --git a/flink-table/flink-table-planner/src/test/resources/list-view-serializer-1.13/test-data b/flink-table/flink-table-planner/src/test/resources/list-view-serializer-1.13/test-data
new file mode 100644
index 0000000..0dc7a2b
Binary files /dev/null and b/flink-table/flink-table-planner/src/test/resources/list-view-serializer-1.13/test-data differ
diff --git a/flink-table/flink-table-planner/src/test/resources/map-view-serializer-1.13/serializer-snapshot b/flink-table/flink-table-planner/src/test/resources/map-view-serializer-1.13/serializer-snapshot
new file mode 100644
index 0000000..8841658
Binary files /dev/null and b/flink-table/flink-table-planner/src/test/resources/map-view-serializer-1.13/serializer-snapshot differ
diff --git a/flink-table/flink-table-planner/src/test/resources/map-view-serializer-1.13/test-data b/flink-table/flink-table-planner/src/test/resources/map-view-serializer-1.13/test-data
new file mode 100644
index 0000000..6ad644f
Binary files /dev/null and b/flink-table/flink-table-planner/src/test/resources/map-view-serializer-1.13/test-data differ
diff --git a/flink-tests/src/test/java/org/apache/flink/test/checkpointing/utils/StatefulJobSavepointMigrationITCase.java b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/utils/StatefulJobSavepointMigrationITCase.java
index be8dd55..c115be2 100644
--- a/flink-tests/src/test/java/org/apache/flink/test/checkpointing/utils/StatefulJobSavepointMigrationITCase.java
+++ b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/utils/StatefulJobSavepointMigrationITCase.java
@@ -95,7 +95,9 @@ public class StatefulJobSavepointMigrationITCase extends SavepointMigrationTestB
Tuple2.of(MigrationVersion.v1_11, StateBackendLoader.MEMORY_STATE_BACKEND_NAME),
Tuple2.of(MigrationVersion.v1_11, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME),
Tuple2.of(MigrationVersion.v1_12, StateBackendLoader.MEMORY_STATE_BACKEND_NAME),
- Tuple2.of(MigrationVersion.v1_12, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME));
+ Tuple2.of(MigrationVersion.v1_12, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME),
+ Tuple2.of(MigrationVersion.v1_13, StateBackendLoader.MEMORY_STATE_BACKEND_NAME),
+ Tuple2.of(MigrationVersion.v1_13, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME));
}
private final MigrationVersion testMigrateVersion;
diff --git a/flink-tests/src/test/java/org/apache/flink/test/checkpointing/utils/StatefulJobWBroadcastStateMigrationITCase.java b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/utils/StatefulJobWBroadcastStateMigrationITCase.java
index 007014b..7861269 100644
--- a/flink-tests/src/test/java/org/apache/flink/test/checkpointing/utils/StatefulJobWBroadcastStateMigrationITCase.java
+++ b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/utils/StatefulJobWBroadcastStateMigrationITCase.java
@@ -79,7 +79,9 @@ public class StatefulJobWBroadcastStateMigrationITCase extends SavepointMigratio
Tuple2.of(MigrationVersion.v1_11, StateBackendLoader.MEMORY_STATE_BACKEND_NAME),
Tuple2.of(MigrationVersion.v1_11, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME),
Tuple2.of(MigrationVersion.v1_12, StateBackendLoader.MEMORY_STATE_BACKEND_NAME),
- Tuple2.of(MigrationVersion.v1_12, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME));
+ Tuple2.of(MigrationVersion.v1_12, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME),
+ Tuple2.of(MigrationVersion.v1_13, StateBackendLoader.MEMORY_STATE_BACKEND_NAME),
+ Tuple2.of(MigrationVersion.v1_13, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME));
}
private final MigrationVersion testMigrateVersion;
diff --git a/flink-tests/src/test/java/org/apache/flink/test/migration/TypeSerializerSnapshotMigrationITCase.java b/flink-tests/src/test/java/org/apache/flink/test/migration/TypeSerializerSnapshotMigrationITCase.java
index 7964463..f4a7a2d 100644
--- a/flink-tests/src/test/java/org/apache/flink/test/migration/TypeSerializerSnapshotMigrationITCase.java
+++ b/flink-tests/src/test/java/org/apache/flink/test/migration/TypeSerializerSnapshotMigrationITCase.java
@@ -97,7 +97,9 @@ public class TypeSerializerSnapshotMigrationITCase extends SavepointMigrationTes
Tuple2.of(MigrationVersion.v1_11, StateBackendLoader.MEMORY_STATE_BACKEND_NAME),
Tuple2.of(MigrationVersion.v1_11, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME),
Tuple2.of(MigrationVersion.v1_12, StateBackendLoader.MEMORY_STATE_BACKEND_NAME),
- Tuple2.of(MigrationVersion.v1_12, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME));
+ Tuple2.of(MigrationVersion.v1_12, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME),
+ Tuple2.of(MigrationVersion.v1_13, StateBackendLoader.MEMORY_STATE_BACKEND_NAME),
+ Tuple2.of(MigrationVersion.v1_13, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME));
}
private final MigrationVersion testMigrateVersion;
diff --git a/flink-tests/src/test/java/org/apache/flink/test/state/operator/restore/keyed/AbstractKeyedOperatorRestoreTestBase.java b/flink-tests/src/test/java/org/apache/flink/test/state/operator/restore/keyed/AbstractKeyedOperatorRestoreTestBase.java
index 4fa876a..2b0b290 100644
--- a/flink-tests/src/test/java/org/apache/flink/test/state/operator/restore/keyed/AbstractKeyedOperatorRestoreTestBase.java
+++ b/flink-tests/src/test/java/org/apache/flink/test/state/operator/restore/keyed/AbstractKeyedOperatorRestoreTestBase.java
@@ -49,7 +49,8 @@ public abstract class AbstractKeyedOperatorRestoreTestBase extends AbstractOpera
MigrationVersion.v1_9,
MigrationVersion.v1_10,
MigrationVersion.v1_11,
- MigrationVersion.v1_12);
+ MigrationVersion.v1_12,
+ MigrationVersion.v1_13);
}
public AbstractKeyedOperatorRestoreTestBase(MigrationVersion migrationVersion) {
diff --git a/flink-tests/src/test/java/org/apache/flink/test/state/operator/restore/unkeyed/AbstractNonKeyedOperatorRestoreTestBase.java b/flink-tests/src/test/java/org/apache/flink/test/state/operator/restore/unkeyed/AbstractNonKeyedOperatorRestoreTestBase.java
index c0317dd..fdfa1af 100644
--- a/flink-tests/src/test/java/org/apache/flink/test/state/operator/restore/unkeyed/AbstractNonKeyedOperatorRestoreTestBase.java
+++ b/flink-tests/src/test/java/org/apache/flink/test/state/operator/restore/unkeyed/AbstractNonKeyedOperatorRestoreTestBase.java
@@ -56,7 +56,8 @@ public abstract class AbstractNonKeyedOperatorRestoreTestBase
MigrationVersion.v1_9,
MigrationVersion.v1_10,
MigrationVersion.v1_11,
- MigrationVersion.v1_12);
+ MigrationVersion.v1_12,
+ MigrationVersion.v1_13);
}
protected AbstractNonKeyedOperatorRestoreTestBase(MigrationVersion migrationVersion) {
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.13-rocksdb-savepoint/_metadata b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.13-rocksdb-savepoint/_metadata
new file mode 100644
index 0000000..851c5cf
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.13-rocksdb-savepoint/_metadata differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.13-savepoint/_metadata b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.13-savepoint/_metadata
new file mode 100644
index 0000000..52ba6b7
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.13-savepoint/_metadata differ
diff --git a/flink-tests/src/test/resources/new-stateful-udf-migration-itcase-flink1.13-rocksdb-savepoint/_metadata b/flink-tests/src/test/resources/new-stateful-udf-migration-itcase-flink1.13-rocksdb-savepoint/_metadata
new file mode 100644
index 0000000..62078b4
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-udf-migration-itcase-flink1.13-rocksdb-savepoint/_metadata differ
diff --git a/flink-tests/src/test/resources/new-stateful-udf-migration-itcase-flink1.13-savepoint/_metadata b/flink-tests/src/test/resources/new-stateful-udf-migration-itcase-flink1.13-savepoint/_metadata
new file mode 100644
index 0000000..d9fee41
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-udf-migration-itcase-flink1.13-savepoint/_metadata differ
diff --git a/flink-tests/src/test/resources/operatorstate/complexKeyed-flink1.13/_metadata b/flink-tests/src/test/resources/operatorstate/complexKeyed-flink1.13/_metadata
new file mode 100644
index 0000000..1181ae3
Binary files /dev/null and b/flink-tests/src/test/resources/operatorstate/complexKeyed-flink1.13/_metadata differ
diff --git a/flink-tests/src/test/resources/operatorstate/nonKeyed-flink1.13/_metadata b/flink-tests/src/test/resources/operatorstate/nonKeyed-flink1.13/_metadata
new file mode 100644
index 0000000..65116bc
Binary files /dev/null and b/flink-tests/src/test/resources/operatorstate/nonKeyed-flink1.13/_metadata differ
diff --git a/flink-tests/src/test/resources/stateful-scala-udf-migration-itcase-flink1.13-jobmanager-savepoint/_metadata b/flink-tests/src/test/resources/stateful-scala-udf-migration-itcase-flink1.13-jobmanager-savepoint/_metadata
new file mode 100644
index 0000000..57c25ff
Binary files /dev/null and b/flink-tests/src/test/resources/stateful-scala-udf-migration-itcase-flink1.13-jobmanager-savepoint/_metadata differ
diff --git a/flink-tests/src/test/resources/stateful-scala-udf-migration-itcase-flink1.13-rocksdb-savepoint/_metadata b/flink-tests/src/test/resources/stateful-scala-udf-migration-itcase-flink1.13-rocksdb-savepoint/_metadata
new file mode 100644
index 0000000..24636f5
Binary files /dev/null and b/flink-tests/src/test/resources/stateful-scala-udf-migration-itcase-flink1.13-rocksdb-savepoint/_metadata differ
diff --git a/flink-tests/src/test/resources/stateful-scala-with-broadcast-udf-migration-itcase-flink1.13-jobmanager-savepoint/_metadata b/flink-tests/src/test/resources/stateful-scala-with-broadcast-udf-migration-itcase-flink1.13-jobmanager-savepoint/_metadata
new file mode 100644
index 0000000..89c31eb
Binary files /dev/null and b/flink-tests/src/test/resources/stateful-scala-with-broadcast-udf-migration-itcase-flink1.13-jobmanager-savepoint/_metadata differ
diff --git a/flink-tests/src/test/resources/stateful-scala-with-broadcast-udf-migration-itcase-flink1.13-rocksdb-savepoint/_metadata b/flink-tests/src/test/resources/stateful-scala-with-broadcast-udf-migration-itcase-flink1.13-rocksdb-savepoint/_metadata
new file mode 100644
index 0000000..0615aa8
Binary files /dev/null and b/flink-tests/src/test/resources/stateful-scala-with-broadcast-udf-migration-itcase-flink1.13-rocksdb-savepoint/_metadata differ
diff --git a/flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.13-rocksdb-savepoint/_metadata b/flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.13-rocksdb-savepoint/_metadata
new file mode 100644
index 0000000..f49e9f4
Binary files /dev/null and b/flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.13-rocksdb-savepoint/_metadata differ
diff --git a/flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.13-savepoint/_metadata b/flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.13-savepoint/_metadata
new file mode 100644
index 0000000..5994faf
Binary files /dev/null and b/flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.13-savepoint/_metadata differ
diff --git a/flink-tests/src/test/scala/org/apache/flink/api/scala/migration/StatefulJobSavepointMigrationITCase.scala b/flink-tests/src/test/scala/org/apache/flink/api/scala/migration/StatefulJobSavepointMigrationITCase.scala
index 28cef3b..916a319 100644
--- a/flink-tests/src/test/scala/org/apache/flink/api/scala/migration/StatefulJobSavepointMigrationITCase.scala
+++ b/flink-tests/src/test/scala/org/apache/flink/api/scala/migration/StatefulJobSavepointMigrationITCase.scala
@@ -68,7 +68,9 @@ object StatefulJobSavepointMigrationITCase {
(MigrationVersion.v1_11, StateBackendLoader.MEMORY_STATE_BACKEND_NAME),
(MigrationVersion.v1_11, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME),
(MigrationVersion.v1_12, StateBackendLoader.MEMORY_STATE_BACKEND_NAME),
- (MigrationVersion.v1_12, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME))
+ (MigrationVersion.v1_12, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME),
+ (MigrationVersion.v1_13, StateBackendLoader.MEMORY_STATE_BACKEND_NAME),
+ (MigrationVersion.v1_13, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME))
}
// TODO to generate savepoints for a specific Flink version / backend type,
diff --git a/flink-tests/src/test/scala/org/apache/flink/api/scala/migration/StatefulJobWBroadcastStateMigrationITCase.scala b/flink-tests/src/test/scala/org/apache/flink/api/scala/migration/StatefulJobWBroadcastStateMigrationITCase.scala
index 8077024..1aba658 100644
--- a/flink-tests/src/test/scala/org/apache/flink/api/scala/migration/StatefulJobWBroadcastStateMigrationITCase.scala
+++ b/flink-tests/src/test/scala/org/apache/flink/api/scala/migration/StatefulJobWBroadcastStateMigrationITCase.scala
@@ -68,7 +68,9 @@ object StatefulJobWBroadcastStateMigrationITCase {
(MigrationVersion.v1_11, StateBackendLoader.MEMORY_STATE_BACKEND_NAME),
(MigrationVersion.v1_11, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME),
(MigrationVersion.v1_12, StateBackendLoader.MEMORY_STATE_BACKEND_NAME),
- (MigrationVersion.v1_12, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME))
+ (MigrationVersion.v1_12, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME),
+ (MigrationVersion.v1_13, StateBackendLoader.MEMORY_STATE_BACKEND_NAME),
+ (MigrationVersion.v1_13, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME))
}
// TODO to generate savepoints for a specific Flink version / backend type,
[flink] 01/02: [hotfix][state][test] Add test file generation guide
in AbstractOperatorRestoreTestBase
Posted by xt...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
xtsong pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 77b9a00de2e9da44149038c47c52137f0f1ade43
Author: tsreaper <ts...@gmail.com>
AuthorDate: Tue Aug 3 10:21:49 2021 +0800
[hotfix][state][test] Add test file generation guide in AbstractOperatorRestoreTestBase
---
.../test/state/operator/restore/AbstractOperatorRestoreTestBase.java | 4 ++++
1 file changed, 4 insertions(+)
diff --git a/flink-tests/src/test/java/org/apache/flink/test/state/operator/restore/AbstractOperatorRestoreTestBase.java b/flink-tests/src/test/java/org/apache/flink/test/state/operator/restore/AbstractOperatorRestoreTestBase.java
index 010fb4f..fbee649 100644
--- a/flink-tests/src/test/java/org/apache/flink/test/state/operator/restore/AbstractOperatorRestoreTestBase.java
+++ b/flink-tests/src/test/java/org/apache/flink/test/state/operator/restore/AbstractOperatorRestoreTestBase.java
@@ -61,6 +61,10 @@ import static org.junit.Assert.assertNotNull;
* <p>The verification is done in 2 Steps: Step 1: Migrate the job to the newer version by
* submitting the same job used for the old version savepoint, and create a new savepoint. Step 2:
* Modify the job topology, and restore from the savepoint created in step 1.
+ *
+ * <p>The savepoint _metadata file for the current branch is stored in the savepointPath in {@link
+ * AbstractOperatorRestoreTestBase#migrateJob}, please create the corresponding test resource
+ * directory and copy the _metadata file by hand.
*/
public abstract class AbstractOperatorRestoreTestBase extends TestLogger {