You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by pn...@apache.org on 2022/11/04 16:45:15 UTC
[flink] branch master updated (db3244a6ac2 -> 32cc0143753)
This is an automated email from the ASF dual-hosted git repository.
pnowojski pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from db3244a6ac2 [FLINK-28449][tests][JUnit5 migration] flink-parquet (#20230)
add 1e131d2a777 [FLINK-29807][core] Add support for more verbose VersionMismatched error
add 2a4463cd478 [FLINK-29807][tests] Drop support for < 1.8 snapshots in TypeSerializerSnapshotMigrationITCase
add b186e3f69df [FLINK-29807][tests] Drop support for < 1.8 snapshots in TupleSerializerCompatibilityTest
add c981d0d7114 [FLINK-29807][tests] Drop support for < 1.8 snapshots in FlinkKafkaConsumerBaseMigrationTest
add 6b5898d397a [FLINK-29807][tests] Drop support for < 1.8 snapshots in HeapKeyedStateBackendSnapshotMigrationTest
add 5d881e8d690 [FLINK-29807][tests] Drop support for < 1.8 snapshots in WindowOperatorMigrationTest
add 00acf074420 [FLINK-29807][tests] Drop support for < 1.8 snapshots in ContinuousFileProcessingMigrationTest
add 5eb70e9e97b [FLINK-29807][tests] Drop support for < 1.8 snapshots in Abstract(Non)KeyedOperatorRestoreTestBase
add 4a8e2390cf3 [FLINK-29807][tests] Drop support for < 1.8 snapshots in StatefulJob*MigrationITCase
add f195f056300 [FLINK-29807][tests] Drop support for < 1.8 snapshots in LegacyStatefulJobMigrationITCase
add 431e41f0cb9 [FLINK-29807][tests] Drop support for < 1.8 snapshots in CEPMigrationTest
add 9b3cf5dcb67 [FLINK-29807][tests] Drop support for < 1.8 snapshots in FlinkKinesisConsumerMigrationTest
add 294814c2113 [FLINK-29807][tests] Limit support in TypeSerializerUpgradeTestBase to only Flink 1.8+ snapshots
add 9bf0d9f2c2b [FLINK-29807][streaming][checkpointing] Remove long deprecated TypeSerializerConfigSnapshot class
add 5c2533295ad [FLINK-29807][streaming][checkpointing] Remove no longer needed and used StateMetaInfoReaders
add 67fd0b8e995 [FLINK-29807][serializers] Clean up serialization stack after removal of TypeSerializerSnapshotConfig
add 5f328a1e56f [FLINK-29807][streaming] exlclude CoGroupedStreams$UnionSerializerConfigSnapshot from japicmp
add 7c6f0802e41 [FLINK-29807][streaming] Remove no longer used TypeSerializerSerializationUtil
add 32cc0143753 [FLINK-29807][tests] Clean up archunit-violations.
No new revisions were added by this update.
Summary of changes:
.../7602816f-5c01-4b7a-9e3e-235dfedec245 | 3 -
.../kafka/FlinkKafkaConsumerBaseMigrationTest.java | 2 +-
...er-migration-test-flink1.4-empty-state-snapshot | Bin 6471 -> 0 bytes
...kafka-consumer-migration-test-flink1.4-snapshot | Bin 6525 -> 0 bytes
...er-migration-test-flink1.5-empty-state-snapshot | Bin 6469 -> 0 bytes
...kafka-consumer-migration-test-flink1.5-snapshot | Bin 6523 -> 0 bytes
...er-migration-test-flink1.6-empty-state-snapshot | Bin 6620 -> 0 bytes
...kafka-consumer-migration-test-flink1.6-snapshot | Bin 6674 -> 0 bytes
...er-migration-test-flink1.7-empty-state-snapshot | Bin 8487 -> 0 bytes
...kafka-consumer-migration-test-flink1.7-snapshot | Bin 8541 -> 0 bytes
.../kinesis/FlinkKinesisConsumerMigrationTest.java | 3 -
...consumer-migration-test-flink1.3-empty-snapshot | Bin 13975 -> 0 bytes
...nesis-consumer-migration-test-flink1.3-snapshot | Bin 14043 -> 0 bytes
...consumer-migration-test-flink1.4-empty-snapshot | Bin 13147 -> 0 bytes
...nesis-consumer-migration-test-flink1.4-snapshot | Bin 13215 -> 0 bytes
...consumer-migration-test-flink1.7-empty-snapshot | Bin 18539 -> 0 bytes
...nesis-consumer-migration-test-flink1.7-snapshot | Bin 18607 -> 0 bytes
.../java/typeutils/runtime/WritableSerializer.java | 34 -
.../apache/flink/api/common/CodeAnalysisMode.java | 45 --
.../BackwardsCompatibleSerializerSnapshot.java | 100 ---
.../api/common/typeutils/CompositeSerializer.java | 25 -
.../CompositeTypeSerializerConfigSnapshot.java | 113 ----
.../GenericTypeSerializerConfigSnapshot.java | 92 ---
.../NestedSerializersSnapshotDelegate.java | 22 +-
.../ParameterlessTypeSerializerConfig.java | 123 ----
.../typeutils/TypeSerializerConfigSnapshot.java | 216 ------
.../typeutils/TypeSerializerSerializationUtil.java | 352 ----------
.../common/typeutils/TypeSerializerSnapshot.java | 13 -
.../TypeSerializerSnapshotSerializationUtil.java | 101 +--
.../api/common/typeutils/TypeSerializerUtils.java | 41 +-
.../base/CollectionSerializerConfigSnapshot.java | 69 --
.../api/common/typeutils/base/EnumSerializer.java | 132 ----
.../base/GenericArraySerializerConfigSnapshot.java | 19 +-
.../base/MapSerializerConfigSnapshot.java | 75 ---
.../typeutils/runtime/CopyableValueSerializer.java | 28 -
.../runtime/EitherSerializerConfigSnapshot.java | 69 --
.../runtime/EitherSerializerSnapshot.java | 12 +-
.../java/typeutils/runtime/KryoRegistration.java | 29 +-
.../KryoRegistrationSerializerConfigSnapshot.java | 289 --------
.../java/typeutils/runtime/NullableSerializer.java | 41 --
.../api/java/typeutils/runtime/PojoSerializer.java | 425 ------------
.../runtime/PojoSerializerSnapshotData.java | 12 +-
.../api/java/typeutils/runtime/RowSerializer.java | 40 --
.../java/typeutils/runtime/Tuple0Serializer.java | 15 +-
.../java/typeutils/runtime/TupleSerializer.java | 27 +-
.../runtime/TupleSerializerConfigSnapshot.java | 92 ---
.../java/typeutils/runtime/ValueSerializer.java | 29 -
.../typeutils/runtime/kryo/KryoSerializer.java | 39 --
.../flink/core/io/VersionedIOReadableWritable.java | 17 +-
.../org/apache/flink/util/InstantiationUtil.java | 100 +--
.../api/common/typeutils/SerializerTestBase.java | 5 +-
.../TypeSerializerSerializationUtilTest.java | 467 -------------
.../typeutils/TypeSerializerSnapshotTest.java | 177 -----
.../typeutils/TypeSerializerUpgradeTestBase.java | 38 +-
.../base/EnumSerializerCompatibilityTest.java | 4 +-
.../common/typeutils/base/EnumSerializerTest.java | 7 +-
.../java/typeutils/runtime/PojoSerializerTest.java | 28 +-
.../kryo/KryoSerializerCompatibilityTest.java | 58 +-
.../avro/typeutils/AvroSerializerSnapshotTest.java | 4 +-
.../ContinuousFileProcessingMigrationTest.java | 5 -
...-migration-test-1496532000000-flink1.3-snapshot | Bin 537 -> 0 bytes
...-migration-test-1516897628000-flink1.4-snapshot | Bin 537 -> 0 bytes
...-migration-test-1533639934000-flink1.5-snapshot | Bin 535 -> 0 bytes
...-migration-test-1534696817000-flink1.6-snapshot | Bin 616 -> 0 bytes
...-migration-test-1544024599000-flink1.7-snapshot | Bin 375 -> 0 bytes
.../reader-migration-test-flink1.3-snapshot | Bin 2823 -> 0 bytes
.../reader-migration-test-flink1.4-snapshot | Bin 2823 -> 0 bytes
.../reader-migration-test-flink1.5-snapshot | Bin 2821 -> 0 bytes
.../reader-migration-test-flink1.6-snapshot | Bin 2902 -> 0 bytes
.../reader-migration-test-flink1.7-snapshot | Bin 2890 -> 0 bytes
.../api/java/io/CollectionInputFormatTest.java | 4 +-
.../main/java/org/apache/flink/cep/nfa/NFA.java | 38 --
.../org/apache/flink/cep/nfa/SharedBuffer.java | 39 --
.../flink/cep/nfa/sharedbuffer/Lockable.java | 20 -
.../flink/cep/operator/CEPMigrationTest.java | 2 +-
...cep-migration-after-branching-flink1.6-snapshot | Bin 30343 -> 0 bytes
...cep-migration-after-branching-flink1.7-snapshot | Bin 28135 -> 0 bytes
.../cep-migration-conditions-flink1.6-snapshot | Bin 29998 -> 0 bytes
.../cep-migration-conditions-flink1.7-snapshot | Bin 27790 -> 0 bytes
...ion-single-pattern-afterwards-flink1.6-snapshot | Bin 29752 -> 0 bytes
...ion-single-pattern-afterwards-flink1.7-snapshot | Bin 27544 -> 0 bytes
...igration-starting-new-pattern-flink1.6-snapshot | Bin 30151 -> 0 bytes
...igration-starting-new-pattern-flink1.7-snapshot | Bin 27943 -> 0 bytes
.../flink/runtime/state/ArrayListSerializer.java | 32 +-
.../state/KeyedBackendSerializationProxy.java | 52 +-
.../state/OperatorBackendSerializationProxy.java | 4 +-
.../state/metainfo/LegacyStateMetaInfoReaders.java | 237 -------
.../StateMetaInfoSnapshotReadersWriters.java | 161 +----
.../flink/runtime/state/ttl/TtlStateFactory.java | 25 +-
.../flink/runtime/jobgraph/JobGraphTest.java | 2 +-
.../testutils/types/IntListSerializer.java | 4 +-
.../testutils/types/IntPairSerializer.java | 4 +-
.../flink/runtime/query/KvStateRegistryTest.java | 4 +-
.../runtime/state/SerializationProxiesTest.java | 9 +-
...HeapKeyedStateBackendSnapshotMigrationTest.java | 213 ------
.../ScalaCaseClassSerializerSnapshot.java | 16 -
.../ScalaOptionSerializerConfigSnapshot.java | 65 --
.../ScalaTrySerializerConfigSnapshot.java | 66 --
.../TraversableSerializerConfigSnapshot.java | 69 --
.../Tuple2CaseClassSerializerSnapshot.java | 9 -
.../scala/org/apache/flink/api/scala/package.scala | 25 +-
.../api/scala/typeutils/EitherSerializer.scala | 10 -
.../api/scala/typeutils/EnumValueSerializer.scala | 112 +---
.../api/scala/typeutils/OptionSerializer.scala | 28 -
.../scala/typeutils/ScalaCaseClassSerializer.scala | 27 +-
.../flink/api/scala/typeutils/TrySerializer.scala | 27 -
.../flink-1.3.2-scala-types-serializer-data | Bin 97 -> 0 bytes
.../flink-1.3.2-scala-types-serializer-snapshot | Bin 7634 -> 0 bytes
.../runtime/TupleSerializerCompatibilityTest.scala | 92 ---
...TupleSerializerCompatibilityTestGenerator.scala | 93 ---
.../EnumValueSerializerCompatibilityTest.scala | 11 +-
.../scala/typeutils/InstantiationUtilTest.scala | 2 +-
.../restore/ChangelogBackendLogApplier.java | 4 +-
.../streaming/api/datastream/CoGroupedStreams.java | 44 --
.../functions/sink/TwoPhaseCommitSinkFunction.java | 48 --
.../api/operators/InternalTimersSnapshot.java | 6 +-
.../InternalTimersSnapshotReaderWriters.java | 122 +---
.../streaming/api/operators/TimerSerializer.java | 55 --
.../api/operators/co/IntervalJoinOperator.java | 37 --
.../streamrecord/StreamElementSerializer.java | 32 -
.../operators/InternalTimerServiceImplTest.java | 10 -
.../windowing/WindowOperatorMigrationTest.java | 2 +-
...gration-test-apply-event-time-flink1.3-snapshot | Bin 4629 -> 0 bytes
...gration-test-apply-event-time-flink1.4-snapshot | Bin 4630 -> 0 bytes
...gration-test-apply-event-time-flink1.5-snapshot | Bin 4980 -> 0 bytes
...gration-test-apply-event-time-flink1.6-snapshot | Bin 7196 -> 0 bytes
...gration-test-apply-event-time-flink1.7-snapshot | Bin 6465 -> 0 bytes
...on-test-apply-processing-time-flink1.3-snapshot | Bin 4521 -> 0 bytes
...on-test-apply-processing-time-flink1.4-snapshot | Bin 4522 -> 0 bytes
...on-test-apply-processing-time-flink1.5-snapshot | Bin 4872 -> 0 bytes
...on-test-apply-processing-time-flink1.6-snapshot | Bin 7088 -> 0 bytes
...on-test-apply-processing-time-flink1.7-snapshot | Bin 6357 -> 0 bytes
...tion-test-kryo-serialized-key-flink1.3-snapshot | Bin 11298 -> 0 bytes
...tion-test-kryo-serialized-key-flink1.4-snapshot | Bin 9539 -> 0 bytes
...tion-test-kryo-serialized-key-flink1.5-snapshot | Bin 10279 -> 0 bytes
...tion-test-kryo-serialized-key-flink1.6-snapshot | Bin 16931 -> 0 bytes
...tion-test-kryo-serialized-key-flink1.7-snapshot | Bin 21981 -> 0 bytes
...ration-test-reduce-event-time-flink1.3-snapshot | Bin 3496 -> 0 bytes
...ration-test-reduce-event-time-flink1.4-snapshot | Bin 3497 -> 0 bytes
...ration-test-reduce-event-time-flink1.5-snapshot | Bin 3840 -> 0 bytes
...ration-test-reduce-event-time-flink1.6-snapshot | Bin 6060 -> 0 bytes
...ration-test-reduce-event-time-flink1.7-snapshot | Bin 6329 -> 0 bytes
...n-test-reduce-processing-time-flink1.3-snapshot | Bin 3437 -> 0 bytes
...n-test-reduce-processing-time-flink1.4-snapshot | Bin 3438 -> 0 bytes
...n-test-reduce-processing-time-flink1.5-snapshot | Bin 3781 -> 0 bytes
...n-test-reduce-processing-time-flink1.6-snapshot | Bin 6001 -> 0 bytes
...n-test-reduce-processing-time-flink1.7-snapshot | Bin 6270 -> 0 bytes
...session-with-stateful-trigger-flink1.3-snapshot | Bin 8679 -> 0 bytes
...session-with-stateful-trigger-flink1.4-snapshot | Bin 8680 -> 0 bytes
...session-with-stateful-trigger-flink1.5-snapshot | Bin 9037 -> 0 bytes
...session-with-stateful-trigger-flink1.6-snapshot | Bin 11401 -> 0 bytes
...session-with-stateful-trigger-flink1.7-snapshot | Bin 9972 -> 0 bytes
...on-with-stateful-trigger-mint-flink1.3-snapshot | Bin 7650 -> 0 bytes
...on-with-stateful-trigger-mint-flink1.4-snapshot | Bin 7651 -> 0 bytes
...on-with-stateful-trigger-mint-flink1.5-snapshot | Bin 8008 -> 0 bytes
...on-with-stateful-trigger-mint-flink1.6-snapshot | Bin 10296 -> 0 bytes
...on-with-stateful-trigger-mint-flink1.7-snapshot | Bin 9112 -> 0 bytes
.../flink/table/dataview/ListViewSerializer.java | 22 -
.../flink/table/dataview/MapViewSerializer.java | 23 -
.../runtime/typeutils/SerializerTestUtil.java | 5 +-
.../LegacyStatefulJobSavepointMigrationITCase.java | 725 ---------------------
.../StatefulJobSnapshotMigrationITCase.java | 4 +-
.../StatefulJobWBroadcastStateMigrationITCase.java | 4 +-
.../TypeSerializerSnapshotMigrationITCase.java | 372 -----------
.../AbstractKeyedOperatorRestoreTestBase.java | 2 +-
.../AbstractNonKeyedOperatorRestoreTestBase.java | 2 +-
.../_metadata | Bin 21096 -> 0 bytes
.../_metadata | Bin 21096 -> 0 bytes
.../_metadata | Bin 22478 -> 0 bytes
.../_metadata | Bin 42726 -> 0 bytes
.../_metadata | Bin 17802 -> 0 bytes
.../_metadata | Bin 37882 -> 0 bytes
.../_metadata | Bin 44848 -> 0 bytes
.../_metadata | Bin 44776 -> 0 bytes
.../_metadata | Bin 44844 -> 0 bytes
.../_metadata | Bin 44772 -> 0 bytes
.../_metadata | Bin 45871 -> 0 bytes
.../_metadata | Bin 79315 -> 0 bytes
.../_metadata | Bin 47107 -> 0 bytes
.../_metadata | Bin 86417 -> 0 bytes
.../operatorstate/complexKeyed-flink1.3/_metadata | Bin 163526 -> 0 bytes
.../operatorstate/complexKeyed-flink1.4/_metadata | Bin 163530 -> 0 bytes
.../operatorstate/complexKeyed-flink1.5/_metadata | Bin 267378 -> 0 bytes
.../operatorstate/complexKeyed-flink1.6/_metadata | Bin 61922 -> 0 bytes
.../operatorstate/complexKeyed-flink1.7/_metadata | Bin 62398 -> 0 bytes
.../operatorstate/nonKeyed-flink1.3/_metadata | Bin 6248 -> 0 bytes
.../operatorstate/nonKeyed-flink1.4/_metadata | Bin 6248 -> 0 bytes
.../operatorstate/nonKeyed-flink1.5/_metadata | Bin 6224 -> 0 bytes
.../operatorstate/nonKeyed-flink1.6/_metadata | Bin 7196 -> 0 bytes
.../operatorstate/nonKeyed-flink1.7/_metadata | Bin 7052 -> 0 bytes
.../_metadata | Bin 32810 -> 0 bytes
.../_metadata | Bin 32738 -> 0 bytes
.../_metadata | Bin 1287 -> 0 bytes
.../_metadata | Bin 1257 -> 0 bytes
.../_metadata | Bin 1266 -> 0 bytes
.../_metadata | Bin 1236 -> 0 bytes
.../_metadata | Bin 1266 -> 0 bytes
.../_metadata | Bin 1236 -> 0 bytes
.../_metadata | Bin 1266 -> 0 bytes
.../_metadata | Bin 1266 -> 0 bytes
.../_metadata | Bin 1266 -> 0 bytes
.../_metadata | Bin 1266 -> 0 bytes
.../95ac2fd3-cd2e-458d-b7a3-eeebb77c0ea7 | Bin 609 -> 0 bytes
.../_metadata | Bin 381 -> 0 bytes
.../ea58951f-6090-4285-802f-8eacefd354cf | Bin 292 -> 0 bytes
.../213443f4-6e70-4333-a4cd-64cc6e210de1 | Bin 292 -> 0 bytes
.../213c4746-830c-4da3-80ec-01a41ab78aa3 | Bin 609 -> 0 bytes
.../_metadata | Bin 381 -> 0 bytes
.../7a28d2df-54c8-4415-b055-1e48e83427ed | Bin 639 -> 0 bytes
.../_metadata | Bin 343 -> 0 bytes
.../e00ed3e4-e8af-4ead-8e2e-5477fcb74780 | Bin 292 -> 0 bytes
.../0fb32bfd-093a-43d6-b1cc-e3ae9f277e4b | Bin 639 -> 0 bytes
.../1b2988c1-ec2f-4fa2-af44-51ae2f21443d | Bin 292 -> 0 bytes
.../_metadata | Bin 381 -> 0 bytes
.../6e1f6918-2e88-4357-82c7-1bdf533ef301 | Bin 292 -> 0 bytes
.../8936e936-8b0f-40ae-85c9-82907b0ee605 | Bin 639 -> 0 bytes
.../_metadata | Bin 343 -> 0 bytes
.../10e5c37a-3ca9-48f9-b06c-95fd44f0b996 | Bin 292 -> 0 bytes
.../58b28015-e14e-4514-91f1-3cc4900708ab | Bin 639 -> 0 bytes
.../_metadata | Bin 343 -> 0 bytes
.../_metadata | Bin 3399 -> 0 bytes
.../_metadata | Bin 3369 -> 0 bytes
.../_metadata | Bin 3408 -> 0 bytes
.../_metadata | Bin 3378 -> 0 bytes
.../_metadata | Bin 3406 -> 0 bytes
.../_metadata | Bin 3376 -> 0 bytes
.../_metadata | Bin 3560 -> 0 bytes
.../_metadata | Bin 3459 -> 0 bytes
.../_metadata | Bin 3302 -> 0 bytes
.../_metadata | Bin 3201 -> 0 bytes
.../_metadata | Bin 1358 -> 0 bytes
.../_metadata | Bin 1257 -> 0 bytes
.../_metadata | Bin 1358 -> 0 bytes
.../_metadata | Bin 1257 -> 0 bytes
pom.xml | 2 +
235 files changed, 179 insertions(+), 6481 deletions(-)
delete mode 100644 flink-connectors/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.4-empty-state-snapshot
delete mode 100644 flink-connectors/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.4-snapshot
delete mode 100644 flink-connectors/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.5-empty-state-snapshot
delete mode 100644 flink-connectors/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.5-snapshot
delete mode 100644 flink-connectors/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.6-empty-state-snapshot
delete mode 100644 flink-connectors/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.6-snapshot
delete mode 100644 flink-connectors/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.7-empty-state-snapshot
delete mode 100644 flink-connectors/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.7-snapshot
delete mode 100644 flink-connectors/flink-connector-kinesis/src/test/resources/kinesis-consumer-migration-test-flink1.3-empty-snapshot
delete mode 100644 flink-connectors/flink-connector-kinesis/src/test/resources/kinesis-consumer-migration-test-flink1.3-snapshot
delete mode 100644 flink-connectors/flink-connector-kinesis/src/test/resources/kinesis-consumer-migration-test-flink1.4-empty-snapshot
delete mode 100644 flink-connectors/flink-connector-kinesis/src/test/resources/kinesis-consumer-migration-test-flink1.4-snapshot
delete mode 100644 flink-connectors/flink-connector-kinesis/src/test/resources/kinesis-consumer-migration-test-flink1.7-empty-snapshot
delete mode 100644 flink-connectors/flink-connector-kinesis/src/test/resources/kinesis-consumer-migration-test-flink1.7-snapshot
delete mode 100644 flink-core/src/main/java/org/apache/flink/api/common/CodeAnalysisMode.java
delete mode 100644 flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java
delete mode 100644 flink-core/src/main/java/org/apache/flink/api/common/typeutils/CompositeTypeSerializerConfigSnapshot.java
delete mode 100644 flink-core/src/main/java/org/apache/flink/api/common/typeutils/GenericTypeSerializerConfigSnapshot.java
delete mode 100644 flink-core/src/main/java/org/apache/flink/api/common/typeutils/ParameterlessTypeSerializerConfig.java
delete mode 100644 flink-core/src/main/java/org/apache/flink/api/common/typeutils/TypeSerializerConfigSnapshot.java
delete mode 100644 flink-core/src/main/java/org/apache/flink/api/common/typeutils/TypeSerializerSerializationUtil.java
delete mode 100644 flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/CollectionSerializerConfigSnapshot.java
delete mode 100644 flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/MapSerializerConfigSnapshot.java
delete mode 100644 flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/EitherSerializerConfigSnapshot.java
delete mode 100644 flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/KryoRegistrationSerializerConfigSnapshot.java
delete mode 100644 flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/TupleSerializerConfigSnapshot.java
delete mode 100644 flink-core/src/test/java/org/apache/flink/api/common/typeutils/TypeSerializerSerializationUtilTest.java
delete mode 100644 flink-core/src/test/java/org/apache/flink/api/common/typeutils/TypeSerializerSnapshotTest.java
delete mode 100644 flink-fs-tests/src/test/resources/monitoring-function-migration-test-1496532000000-flink1.3-snapshot
delete mode 100644 flink-fs-tests/src/test/resources/monitoring-function-migration-test-1516897628000-flink1.4-snapshot
delete mode 100644 flink-fs-tests/src/test/resources/monitoring-function-migration-test-1533639934000-flink1.5-snapshot
delete mode 100644 flink-fs-tests/src/test/resources/monitoring-function-migration-test-1534696817000-flink1.6-snapshot
delete mode 100644 flink-fs-tests/src/test/resources/monitoring-function-migration-test-1544024599000-flink1.7-snapshot
delete mode 100644 flink-fs-tests/src/test/resources/reader-migration-test-flink1.3-snapshot
delete mode 100644 flink-fs-tests/src/test/resources/reader-migration-test-flink1.4-snapshot
delete mode 100644 flink-fs-tests/src/test/resources/reader-migration-test-flink1.5-snapshot
delete mode 100644 flink-fs-tests/src/test/resources/reader-migration-test-flink1.6-snapshot
delete mode 100644 flink-fs-tests/src/test/resources/reader-migration-test-flink1.7-snapshot
delete mode 100644 flink-libraries/flink-cep/src/test/resources/cep-migration-after-branching-flink1.6-snapshot
delete mode 100644 flink-libraries/flink-cep/src/test/resources/cep-migration-after-branching-flink1.7-snapshot
delete mode 100644 flink-libraries/flink-cep/src/test/resources/cep-migration-conditions-flink1.6-snapshot
delete mode 100644 flink-libraries/flink-cep/src/test/resources/cep-migration-conditions-flink1.7-snapshot
delete mode 100644 flink-libraries/flink-cep/src/test/resources/cep-migration-single-pattern-afterwards-flink1.6-snapshot
delete mode 100644 flink-libraries/flink-cep/src/test/resources/cep-migration-single-pattern-afterwards-flink1.7-snapshot
delete mode 100644 flink-libraries/flink-cep/src/test/resources/cep-migration-starting-new-pattern-flink1.6-snapshot
delete mode 100644 flink-libraries/flink-cep/src/test/resources/cep-migration-starting-new-pattern-flink1.7-snapshot
delete mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/state/metainfo/LegacyStateMetaInfoReaders.java
delete mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/state/heap/HeapKeyedStateBackendSnapshotMigrationTest.java
delete mode 100644 flink-scala/src/main/java/org/apache/flink/api/scala/typeutils/ScalaOptionSerializerConfigSnapshot.java
delete mode 100644 flink-scala/src/main/java/org/apache/flink/api/scala/typeutils/ScalaTrySerializerConfigSnapshot.java
delete mode 100644 flink-scala/src/main/java/org/apache/flink/api/scala/typeutils/TraversableSerializerConfigSnapshot.java
delete mode 100644 flink-scala/src/test/resources/flink-1.3.2-scala-types-serializer-data
delete mode 100644 flink-scala/src/test/resources/flink-1.3.2-scala-types-serializer-snapshot
delete mode 100644 flink-scala/src/test/scala/org/apache/flink/api/scala/runtime/TupleSerializerCompatibilityTest.scala
delete mode 100644 flink-scala/src/test/scala/org/apache/flink/api/scala/runtime/TupleSerializerCompatibilityTestGenerator.scala
delete mode 100644 flink-streaming-java/src/test/resources/win-op-migration-test-apply-event-time-flink1.3-snapshot
delete mode 100644 flink-streaming-java/src/test/resources/win-op-migration-test-apply-event-time-flink1.4-snapshot
delete mode 100644 flink-streaming-java/src/test/resources/win-op-migration-test-apply-event-time-flink1.5-snapshot
delete mode 100644 flink-streaming-java/src/test/resources/win-op-migration-test-apply-event-time-flink1.6-snapshot
delete mode 100644 flink-streaming-java/src/test/resources/win-op-migration-test-apply-event-time-flink1.7-snapshot
delete mode 100644 flink-streaming-java/src/test/resources/win-op-migration-test-apply-processing-time-flink1.3-snapshot
delete mode 100644 flink-streaming-java/src/test/resources/win-op-migration-test-apply-processing-time-flink1.4-snapshot
delete mode 100644 flink-streaming-java/src/test/resources/win-op-migration-test-apply-processing-time-flink1.5-snapshot
delete mode 100644 flink-streaming-java/src/test/resources/win-op-migration-test-apply-processing-time-flink1.6-snapshot
delete mode 100644 flink-streaming-java/src/test/resources/win-op-migration-test-apply-processing-time-flink1.7-snapshot
delete mode 100644 flink-streaming-java/src/test/resources/win-op-migration-test-kryo-serialized-key-flink1.3-snapshot
delete mode 100644 flink-streaming-java/src/test/resources/win-op-migration-test-kryo-serialized-key-flink1.4-snapshot
delete mode 100644 flink-streaming-java/src/test/resources/win-op-migration-test-kryo-serialized-key-flink1.5-snapshot
delete mode 100644 flink-streaming-java/src/test/resources/win-op-migration-test-kryo-serialized-key-flink1.6-snapshot
delete mode 100644 flink-streaming-java/src/test/resources/win-op-migration-test-kryo-serialized-key-flink1.7-snapshot
delete mode 100644 flink-streaming-java/src/test/resources/win-op-migration-test-reduce-event-time-flink1.3-snapshot
delete mode 100644 flink-streaming-java/src/test/resources/win-op-migration-test-reduce-event-time-flink1.4-snapshot
delete mode 100644 flink-streaming-java/src/test/resources/win-op-migration-test-reduce-event-time-flink1.5-snapshot
delete mode 100644 flink-streaming-java/src/test/resources/win-op-migration-test-reduce-event-time-flink1.6-snapshot
delete mode 100644 flink-streaming-java/src/test/resources/win-op-migration-test-reduce-event-time-flink1.7-snapshot
delete mode 100644 flink-streaming-java/src/test/resources/win-op-migration-test-reduce-processing-time-flink1.3-snapshot
delete mode 100644 flink-streaming-java/src/test/resources/win-op-migration-test-reduce-processing-time-flink1.4-snapshot
delete mode 100644 flink-streaming-java/src/test/resources/win-op-migration-test-reduce-processing-time-flink1.5-snapshot
delete mode 100644 flink-streaming-java/src/test/resources/win-op-migration-test-reduce-processing-time-flink1.6-snapshot
delete mode 100644 flink-streaming-java/src/test/resources/win-op-migration-test-reduce-processing-time-flink1.7-snapshot
delete mode 100644 flink-streaming-java/src/test/resources/win-op-migration-test-session-with-stateful-trigger-flink1.3-snapshot
delete mode 100644 flink-streaming-java/src/test/resources/win-op-migration-test-session-with-stateful-trigger-flink1.4-snapshot
delete mode 100644 flink-streaming-java/src/test/resources/win-op-migration-test-session-with-stateful-trigger-flink1.5-snapshot
delete mode 100644 flink-streaming-java/src/test/resources/win-op-migration-test-session-with-stateful-trigger-flink1.6-snapshot
delete mode 100644 flink-streaming-java/src/test/resources/win-op-migration-test-session-with-stateful-trigger-flink1.7-snapshot
delete mode 100644 flink-streaming-java/src/test/resources/win-op-migration-test-session-with-stateful-trigger-mint-flink1.3-snapshot
delete mode 100644 flink-streaming-java/src/test/resources/win-op-migration-test-session-with-stateful-trigger-mint-flink1.4-snapshot
delete mode 100644 flink-streaming-java/src/test/resources/win-op-migration-test-session-with-stateful-trigger-mint-flink1.5-snapshot
delete mode 100644 flink-streaming-java/src/test/resources/win-op-migration-test-session-with-stateful-trigger-mint-flink1.6-snapshot
delete mode 100644 flink-streaming-java/src/test/resources/win-op-migration-test-session-with-stateful-trigger-mint-flink1.7-snapshot
delete mode 100644 flink-tests/src/test/java/org/apache/flink/test/checkpointing/LegacyStatefulJobSavepointMigrationITCase.java
delete mode 100644 flink-tests/src/test/java/org/apache/flink/test/migration/TypeSerializerSnapshotMigrationITCase.java
delete mode 100644 flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.5-rocksdb-savepoint/_metadata
delete mode 100644 flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.5-savepoint/_metadata
delete mode 100644 flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.6-rocksdb-savepoint/_metadata
delete mode 100644 flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.6-savepoint/_metadata
delete mode 100644 flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.7-rocksdb-savepoint/_metadata
delete mode 100644 flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.7-savepoint/_metadata
delete mode 100644 flink-tests/src/test/resources/new-stateful-udf-migration-itcase-flink1.4-rocksdb-savepoint/_metadata
delete mode 100644 flink-tests/src/test/resources/new-stateful-udf-migration-itcase-flink1.4-savepoint/_metadata
delete mode 100644 flink-tests/src/test/resources/new-stateful-udf-migration-itcase-flink1.5-rocksdb-savepoint/_metadata
delete mode 100644 flink-tests/src/test/resources/new-stateful-udf-migration-itcase-flink1.5-savepoint/_metadata
delete mode 100644 flink-tests/src/test/resources/new-stateful-udf-migration-itcase-flink1.6-rocksdb-savepoint/_metadata
delete mode 100644 flink-tests/src/test/resources/new-stateful-udf-migration-itcase-flink1.6-savepoint/_metadata
delete mode 100644 flink-tests/src/test/resources/new-stateful-udf-migration-itcase-flink1.7-rocksdb-savepoint/_metadata
delete mode 100644 flink-tests/src/test/resources/new-stateful-udf-migration-itcase-flink1.7-savepoint/_metadata
delete mode 100644 flink-tests/src/test/resources/operatorstate/complexKeyed-flink1.3/_metadata
delete mode 100644 flink-tests/src/test/resources/operatorstate/complexKeyed-flink1.4/_metadata
delete mode 100644 flink-tests/src/test/resources/operatorstate/complexKeyed-flink1.5/_metadata
delete mode 100644 flink-tests/src/test/resources/operatorstate/complexKeyed-flink1.6/_metadata
delete mode 100644 flink-tests/src/test/resources/operatorstate/complexKeyed-flink1.7/_metadata
delete mode 100644 flink-tests/src/test/resources/operatorstate/nonKeyed-flink1.3/_metadata
delete mode 100644 flink-tests/src/test/resources/operatorstate/nonKeyed-flink1.4/_metadata
delete mode 100644 flink-tests/src/test/resources/operatorstate/nonKeyed-flink1.5/_metadata
delete mode 100644 flink-tests/src/test/resources/operatorstate/nonKeyed-flink1.6/_metadata
delete mode 100644 flink-tests/src/test/resources/operatorstate/nonKeyed-flink1.7/_metadata
delete mode 100644 flink-tests/src/test/resources/stateful-udf-migration-itcase-flink1.4-rocksdb-savepoint/_metadata
delete mode 100644 flink-tests/src/test/resources/stateful-udf-migration-itcase-flink1.4-savepoint/_metadata
delete mode 100644 flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.10-rocksdb-savepoint/_metadata
delete mode 100644 flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.10-savepoint/_metadata
delete mode 100644 flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.11-rocksdb-savepoint/_metadata
delete mode 100644 flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.11-savepoint/_metadata
delete mode 100644 flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.12-rocksdb-savepoint/_metadata
delete mode 100644 flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.12-savepoint/_metadata
delete mode 100644 flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.13-rocksdb-savepoint/_metadata
delete mode 100644 flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.13-savepoint/_metadata
delete mode 100644 flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.14-rocksdb-savepoint/_metadata
delete mode 100644 flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.14-savepoint/_metadata
delete mode 100644 flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.15-hashmap-checkpoint/95ac2fd3-cd2e-458d-b7a3-eeebb77c0ea7
delete mode 100644 flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.15-hashmap-checkpoint/_metadata
delete mode 100644 flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.15-hashmap-checkpoint/ea58951f-6090-4285-802f-8eacefd354cf
delete mode 100644 flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.15-hashmap-savepoint-native/213443f4-6e70-4333-a4cd-64cc6e210de1
delete mode 100644 flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.15-hashmap-savepoint-native/213c4746-830c-4da3-80ec-01a41ab78aa3
delete mode 100644 flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.15-hashmap-savepoint-native/_metadata
delete mode 100644 flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.15-hashmap-savepoint/7a28d2df-54c8-4415-b055-1e48e83427ed
delete mode 100644 flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.15-hashmap-savepoint/_metadata
delete mode 100644 flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.15-hashmap-savepoint/e00ed3e4-e8af-4ead-8e2e-5477fcb74780
delete mode 100644 flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.15-rocksdb-checkpoint/0fb32bfd-093a-43d6-b1cc-e3ae9f277e4b
delete mode 100644 flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.15-rocksdb-checkpoint/1b2988c1-ec2f-4fa2-af44-51ae2f21443d
delete mode 100644 flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.15-rocksdb-checkpoint/_metadata
delete mode 100644 flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.15-rocksdb-savepoint-native/6e1f6918-2e88-4357-82c7-1bdf533ef301
delete mode 100644 flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.15-rocksdb-savepoint-native/8936e936-8b0f-40ae-85c9-82907b0ee605
delete mode 100644 flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.15-rocksdb-savepoint-native/_metadata
delete mode 100644 flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.15-rocksdb-savepoint/10e5c37a-3ca9-48f9-b06c-95fd44f0b996
delete mode 100644 flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.15-rocksdb-savepoint/58b28015-e14e-4514-91f1-3cc4900708ab
delete mode 100644 flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.15-rocksdb-savepoint/_metadata
delete mode 100644 flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.3-rocksdb-savepoint/_metadata
delete mode 100644 flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.3-savepoint/_metadata
delete mode 100644 flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.4-rocksdb-savepoint/_metadata
delete mode 100644 flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.4-savepoint/_metadata
delete mode 100644 flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.5-rocksdb-savepoint/_metadata
delete mode 100644 flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.5-savepoint/_metadata
delete mode 100644 flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.6-rocksdb-savepoint/_metadata
delete mode 100644 flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.6-savepoint/_metadata
delete mode 100644 flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.7-rocksdb-savepoint/_metadata
delete mode 100644 flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.7-savepoint/_metadata
delete mode 100644 flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.8-rocksdb-savepoint/_metadata
delete mode 100644 flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.8-savepoint/_metadata
delete mode 100644 flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.9-rocksdb-savepoint/_metadata
delete mode 100644 flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.9-savepoint/_metadata