Skip to content

Commit 4743666

Browse files
tsreaperxintongsong
tsreaper
authored and
xintongsong
committed
[FLINK-23529][core][test] Add Flink 1.13 MigrationVersion
This closes apache#16636
1 parent 77b9a00 commit 4743666

File tree

263 files changed

+50
-15
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

263 files changed

+50
-15
lines changed

‎flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBaseMigrationTest.java

+2-1
Original file line numberDiff line numberDiff line change
@@ -103,7 +103,8 @@ public static Collection<MigrationVersion> parameters() {
103103
MigrationVersion.v1_9,
104104
MigrationVersion.v1_10,
105105
MigrationVersion.v1_11,
106-
MigrationVersion.v1_12);
106+
MigrationVersion.v1_12,
107+
MigrationVersion.v1_13);
107108
}
108109

109110
public FlinkKafkaConsumerBaseMigrationTest(MigrationVersion testMigrateVersion) {

‎flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerMigrationTest.java

+2-1
Original file line numberDiff line numberDiff line change
@@ -48,7 +48,8 @@ public static Collection<MigrationVersion> parameters() {
4848
MigrationVersion.v1_9,
4949
MigrationVersion.v1_10,
5050
MigrationVersion.v1_11,
51-
MigrationVersion.v1_12);
51+
MigrationVersion.v1_12,
52+
MigrationVersion.v1_13);
5253
}
5354

5455
public FlinkKafkaProducerMigrationTest(MigrationVersion testMigrateVersion) {

‎flink-connectors/flink-connector-kafka/src/test/resources/context-state-serializer-1.13/serializer-snapshot

126 Bytes
Binary file not shown.

‎flink-connectors/flink-connector-kafka/src/test/resources/context-state-serializer-1.13/test-data

19 Bytes
Binary file not shown.

‎flink-connectors/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.13-empty-state-snapshot

1.43 KB
Binary file not shown.

‎flink-connectors/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.13-snapshot

1.48 KB
Binary file not shown.

‎flink-connectors/flink-connector-kafka/src/test/resources/kafka-migration-kafka-producer-flink-1.13-snapshot

1.21 KB
Binary file not shown.

‎flink-connectors/flink-connector-kafka/src/test/resources/transaction-state-serializer-1.13/serializer-snapshot

134 Bytes
Binary file not shown.

‎flink-connectors/flink-connector-kafka/src/test/resources/transaction-state-serializer-1.13/test-data

17 Bytes
Binary file not shown.

‎flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumerMigrationTest.java

+2-1
Original file line numberDiff line numberDiff line change
@@ -106,7 +106,8 @@ public static Collection<MigrationVersion> parameters() {
106106
MigrationVersion.v1_9,
107107
MigrationVersion.v1_10,
108108
MigrationVersion.v1_11,
109-
MigrationVersion.v1_12);
109+
MigrationVersion.v1_12,
110+
MigrationVersion.v1_13);
110111
}
111112

112113
public FlinkKinesisConsumerMigrationTest(MigrationVersion testMigrateVersion) {

‎flink-connectors/flink-connector-kinesis/src/test/resources/kinesis-consumer-migration-test-flink1.13-empty-snapshot

2.8 KB
Binary file not shown.

‎flink-connectors/flink-connector-kinesis/src/test/resources/kinesis-consumer-migration-test-flink1.13-snapshot

2.87 KB
Binary file not shown.

‎flink-connectors/flink-hadoop-compatibility/src/test/resources/writeable-serializer-1.13/serializer-snapshot

187 Bytes
Binary file not shown.

‎flink-connectors/flink-hadoop-compatibility/src/test/resources/writeable-serializer-1.13/test-data

7 Bytes
Binary file not shown.

‎flink-core/src/test/java/org/apache/flink/api/common/typeutils/TypeSerializerUpgradeTestBase.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -54,7 +54,7 @@ public abstract class TypeSerializerUpgradeTestBase<PreviousElementT, UpgradedEl
5454
public static final MigrationVersion[] MIGRATION_VERSIONS =
5555
MigrationVersion.v1_11.orHigher().toArray(new MigrationVersion[0]);
5656

57-
public static final MigrationVersion CURRENT_VERSION = MigrationVersion.v1_12;
57+
public static final MigrationVersion CURRENT_VERSION = MigrationVersion.v1_13;
5858

5959
private final TestSpecification<PreviousElementT, UpgradedElementT> testSpecification;
6060

‎flink-core/src/test/java/org/apache/flink/testutils/migration/MigrationVersion.java

+2-1
Original file line numberDiff line numberDiff line change
@@ -44,7 +44,8 @@ public enum MigrationVersion {
4444
v1_9("1.9"),
4545
v1_10("1.10"),
4646
v1_11("1.11"),
47-
v1_12("1.12");
47+
v1_12("1.12"),
48+
v1_13("1.13");
4849

4950
private final String versionStr;
5051

‎flink-core/src/test/resources/big-dec-serializer-1.13/serializer-snapshot

94 Bytes
Binary file not shown.

‎flink-core/src/test/resources/big-dec-serializer-1.13/test-data

24 Bytes
Binary file not shown.

‎flink-core/src/test/resources/big-int-serializer-1.13/serializer-snapshot

94 Bytes
Binary file not shown.

‎flink-core/src/test/resources/big-int-serializer-1.13/test-data

19 Bytes
Binary file not shown.

‎flink-core/src/test/resources/boolean-primitive-array-serializer-1.13/serializer-snapshot

130 Bytes
Binary file not shown.

‎flink-core/src/test/resources/boolean-primitive-array-serializer-1.13/test-data

6 Bytes
Binary file not shown.

‎flink-core/src/test/resources/boolean-serializer-1.13/serializer-snapshot

96 Bytes
Binary file not shown.

‎flink-core/src/test/resources/boolean-serializer-1.13/test-data

+1
Original file line numberDiff line numberDiff line change
@@ -0,0 +1 @@
1+


‎flink-core/src/test/resources/boolean-value-serializer-1.13/serializer-snapshot

106 Bytes
Binary file not shown.

‎flink-core/src/test/resources/boolean-value-serializer-1.13/test-data

+1
Original file line numberDiff line numberDiff line change
@@ -0,0 +1 @@
1+


‎flink-core/src/test/resources/byte-primitive-array-serializer-1.13/serializer-snapshot

124 Bytes
Binary file not shown.

‎flink-core/src/test/resources/byte-primitive-array-serializer-1.13/test-data

14 Bytes
Binary file not shown.

‎flink-core/src/test/resources/byte-serializer-1.13/serializer-snapshot

90 Bytes
Binary file not shown.

‎flink-core/src/test/resources/byte-serializer-1.13/test-data

+1
Original file line numberDiff line numberDiff line change
@@ -0,0 +1 @@
1+
*

‎flink-core/src/test/resources/byte-value-serializer-1.13/serializer-snapshot

100 Bytes
Binary file not shown.

‎flink-core/src/test/resources/byte-value-serializer-1.13/test-data

+1
Original file line numberDiff line numberDiff line change
@@ -0,0 +1 @@
1+
*

‎flink-core/src/test/resources/char-primitive-array-serializer-1.13/serializer-snapshot

124 Bytes
Binary file not shown.

‎flink-core/src/test/resources/char-primitive-array-serializer-1.13/test-data

24 Bytes
Binary file not shown.

‎flink-core/src/test/resources/char-serializer-1.13/serializer-snapshot

90 Bytes
Binary file not shown.

‎flink-core/src/test/resources/char-serializer-1.13/test-data

+1
Original file line numberDiff line numberDiff line change
@@ -0,0 +1 @@
1+
��

‎flink-core/src/test/resources/char-value-serializer-1.13/serializer-snapshot

100 Bytes
Binary file not shown.

‎flink-core/src/test/resources/char-value-serializer-1.13/test-data

2 Bytes
Binary file not shown.

‎flink-core/src/test/resources/copyable-value-serializer-1.13/serializer-snapshot

199 Bytes
Binary file not shown.

‎flink-core/src/test/resources/copyable-value-serializer-1.13/test-data

8 Bytes
Binary file not shown.

‎flink-core/src/test/resources/date-serializer-1.13/serializer-snapshot

90 Bytes
Binary file not shown.

‎flink-core/src/test/resources/date-serializer-1.13/test-data

8 Bytes
Binary file not shown.

‎flink-core/src/test/resources/double-primitive-array-serializer-1.13/serializer-snapshot

128 Bytes
Binary file not shown.

‎flink-core/src/test/resources/double-primitive-array-serializer-1.13/test-data

84 Bytes
Binary file not shown.

‎flink-core/src/test/resources/double-serializer-1.13/serializer-snapshot

94 Bytes
Binary file not shown.

‎flink-core/src/test/resources/double-serializer-1.13/test-data

+1
Original file line numberDiff line numberDiff line change
@@ -0,0 +1 @@
1+
@���1��

‎flink-core/src/test/resources/double-value-serializer-1.13/serializer-snapshot

104 Bytes
Binary file not shown.

‎flink-core/src/test/resources/double-value-serializer-1.13/test-data

+1
Original file line numberDiff line numberDiff line change
@@ -0,0 +1 @@
1+
@���1��

‎flink-core/src/test/resources/either-serializer-1.13/serializer-snapshot

276 Bytes
Binary file not shown.

‎flink-core/src/test/resources/either-serializer-1.13/test-data

+1
Original file line numberDiff line numberDiff line change
@@ -0,0 +1 @@
1+
 ApacheFlink

‎flink-core/src/test/resources/enum-serializer-1.13/serializer-snapshot

188 Bytes
Binary file not shown.

‎flink-core/src/test/resources/enum-serializer-1.13/test-data

4 Bytes
Binary file not shown.

‎flink-core/src/test/resources/enum-serializerreconfig-1.13/serializer-snapshot

163 Bytes
Binary file not shown.

‎flink-core/src/test/resources/enum-serializerreconfig-1.13/test-data

4 Bytes
Binary file not shown.

‎flink-core/src/test/resources/float-primitive-array-serializer-1.13/serializer-snapshot

126 Bytes
Binary file not shown.

‎flink-core/src/test/resources/float-primitive-array-serializer-1.13/test-data

44 Bytes
Binary file not shown.

‎flink-core/src/test/resources/float-serializer-1.13/serializer-snapshot

92 Bytes
Binary file not shown.

‎flink-core/src/test/resources/float-serializer-1.13/test-data

+1
Original file line numberDiff line numberDiff line change
@@ -0,0 +1 @@
1+
B��y

‎flink-core/src/test/resources/float-value-serializer-1.13/serializer-snapshot

102 Bytes
Binary file not shown.

‎flink-core/src/test/resources/float-value-serializer-1.13/test-data

+1
Original file line numberDiff line numberDiff line change
@@ -0,0 +1 @@
1+
B��y

‎flink-core/src/test/resources/generic-array-serializer-1.13/serializer-snapshot

211 Bytes
Binary file not shown.

‎flink-core/src/test/resources/generic-array-serializer-1.13/test-data

19 Bytes
Binary file not shown.

‎flink-core/src/test/resources/int-primitive-array-serializer-1.13/serializer-snapshot

122 Bytes
Binary file not shown.

‎flink-core/src/test/resources/int-primitive-array-serializer-1.13/test-data

44 Bytes
Binary file not shown.

‎flink-core/src/test/resources/int-serializer-1.13/serializer-snapshot

88 Bytes
Binary file not shown.

‎flink-core/src/test/resources/int-serializer-1.13/test-data

4 Bytes
Binary file not shown.

‎flink-core/src/test/resources/int-value-serializer-1.13/serializer-snapshot

98 Bytes
Binary file not shown.

‎flink-core/src/test/resources/int-value-serializer-1.13/test-data

4 Bytes
Binary file not shown.

‎flink-core/src/test/resources/kryo-custom-type-serializer-changed-registration-order-1.13/serializer-snapshot

1.68 KB
Binary file not shown.

‎flink-core/src/test/resources/kryo-custom-type-serializer-changed-registration-order-1.13/test-data

+1
Original file line numberDiff line numberDiff line change
@@ -0,0 +1 @@
1+
Hass�

‎flink-core/src/test/resources/kryo-type-serializer-changed-registration-order-1.13/serializer-snapshot

1.49 KB
Binary file not shown.

‎flink-core/src/test/resources/kryo-type-serializer-changed-registration-order-1.13/test-data

+1
Original file line numberDiff line numberDiff line change
@@ -0,0 +1 @@
1+
Hass�

‎flink-core/src/test/resources/kryo-type-serializer-empty-config-1.13/serializer-snapshot

745 Bytes
Binary file not shown.

‎flink-core/src/test/resources/kryo-type-serializer-empty-config-1.13/test-data

90 Bytes
Binary file not shown.

‎flink-core/src/test/resources/kryo-type-serializer-unrelated-config-after-restore-1.13/serializer-snapshot

745 Bytes
Binary file not shown.

‎flink-core/src/test/resources/kryo-type-serializer-unrelated-config-after-restore-1.13/test-data

90 Bytes
Binary file not shown.

‎flink-core/src/test/resources/list-serializer-1.13/serializer-snapshot

185 Bytes
Binary file not shown.

‎flink-core/src/test/resources/list-serializer-1.13/test-data

17 Bytes
Binary file not shown.

‎flink-core/src/test/resources/long-primitive-array-serializer-1.13/serializer-snapshot

124 Bytes
Binary file not shown.

‎flink-core/src/test/resources/long-primitive-array-serializer-1.13/test-data

84 Bytes
Binary file not shown.

‎flink-core/src/test/resources/long-serializer-1.13/serializer-snapshot

90 Bytes
Binary file not shown.

‎flink-core/src/test/resources/long-serializer-1.13/test-data

8 Bytes
Binary file not shown.

‎flink-core/src/test/resources/long-value-serializer-1.13/serializer-snapshot

100 Bytes
Binary file not shown.

‎flink-core/src/test/resources/long-value-serializer-1.13/test-data

8 Bytes
Binary file not shown.

‎flink-core/src/test/resources/map-serializer-1.13/serializer-snapshot

268 Bytes
Binary file not shown.

‎flink-core/src/test/resources/map-serializer-1.13/test-data

25 Bytes
Binary file not shown.

‎flink-core/src/test/resources/null-value-serializer-1.13/serializer-snapshot

100 Bytes
Binary file not shown.

‎flink-core/src/test/resources/null-value-serializer-1.13/test-data

Whitespace-only changes.

‎flink-core/src/test/resources/nullable-not-padded-serializer-1.13/serializer-snapshot

209 Bytes
Binary file not shown.

‎flink-core/src/test/resources/nullable-not-padded-serializer-1.13/test-data

+1
Original file line numberDiff line numberDiff line change
@@ -0,0 +1 @@
1+


‎flink-core/src/test/resources/nullable-padded-serializer-1.13/serializer-snapshot

209 Bytes
Binary file not shown.

‎flink-core/src/test/resources/nullable-padded-serializer-1.13/test-data

9 Bytes
Binary file not shown.

‎flink-core/src/test/resources/pojo-serializer-identical-schema-1.13/serializer-snapshot

1.19 KB
Binary file not shown.

‎flink-core/src/test/resources/pojo-serializer-identical-schema-1.13/test-data

21 Bytes
Binary file not shown.

‎flink-core/src/test/resources/pojo-serializer-with-different-field-types-1.13/serializer-snapshot

294 Bytes
Binary file not shown.

‎flink-core/src/test/resources/pojo-serializer-with-different-field-types-1.13/test-data

6 Bytes
Binary file not shown.

‎flink-core/src/test/resources/pojo-serializer-with-different-field-types-in-registered-subclass-1.13/serializer-snapshot

2.51 KB
Binary file not shown.

‎flink-core/src/test/resources/pojo-serializer-with-different-field-types-in-registered-subclass-1.13/test-data

24 Bytes
Binary file not shown.

‎flink-core/src/test/resources/pojo-serializer-with-different-subclass-registration-order-1.13/serializer-snapshot

4.27 KB
Binary file not shown.

‎flink-core/src/test/resources/pojo-serializer-with-different-subclass-registration-order-1.13/test-data

21 Bytes
Binary file not shown.

‎flink-core/src/test/resources/pojo-serializer-with-missing-registered-subclass-1.13/serializer-snapshot

4.27 KB
Binary file not shown.

‎flink-core/src/test/resources/pojo-serializer-with-missing-registered-subclass-1.13/test-data

21 Bytes
Binary file not shown.

‎flink-core/src/test/resources/pojo-serializer-with-modified-schema-1.13/serializer-snapshot

686 Bytes
Binary file not shown.

‎flink-core/src/test/resources/pojo-serializer-with-modified-schema-1.13/test-data

28 Bytes
Binary file not shown.

‎flink-core/src/test/resources/pojo-serializer-with-modified-schema-in-registered-subclass-1.13/serializer-snapshot

1.06 KB
Binary file not shown.

‎flink-core/src/test/resources/pojo-serializer-with-modified-schema-in-registered-subclass-1.13/test-data

27 Bytes
Binary file not shown.

‎flink-core/src/test/resources/pojo-serializer-with-new-and-missing-registered-subclasses-1.13/serializer-snapshot

4.27 KB
Binary file not shown.

‎flink-core/src/test/resources/pojo-serializer-with-new-and-missing-registered-subclasses-1.13/test-data

21 Bytes
Binary file not shown.

‎flink-core/src/test/resources/pojo-serializer-with-new-registered-subclass-1.13/serializer-snapshot

2.72 KB
Binary file not shown.

‎flink-core/src/test/resources/pojo-serializer-with-new-registered-subclass-1.13/test-data

134 Bytes
Binary file not shown.

‎flink-core/src/test/resources/pojo-serializer-with-non-registered-subclass-1.13/serializer-snapshot

2.72 KB
Binary file not shown.

‎flink-core/src/test/resources/pojo-serializer-with-non-registered-subclass-1.13/test-data

134 Bytes
Binary file not shown.

‎flink-core/src/test/resources/row-serializer-1.13/serializer-snapshot

465 Bytes
Binary file not shown.

‎flink-core/src/test/resources/row-serializer-1.13/test-data

20 Bytes
Binary file not shown.

‎flink-core/src/test/resources/short-primitive-array-serializer-1.13/serializer-snapshot

126 Bytes
Binary file not shown.

‎flink-core/src/test/resources/short-primitive-array-serializer-1.13/test-data

24 Bytes
Binary file not shown.

‎flink-core/src/test/resources/short-serializer-1.13/serializer-snapshot

92 Bytes
Binary file not shown.

‎flink-core/src/test/resources/short-serializer-1.13/test-data

2 Bytes
Binary file not shown.

‎flink-core/src/test/resources/short-value-serializer-1.13/serializer-snapshot

102 Bytes
Binary file not shown.

‎flink-core/src/test/resources/short-value-serializer-1.13/test-data

2 Bytes
Binary file not shown.

‎flink-core/src/test/resources/sql-date-serializer-1.13/serializer-snapshot

96 Bytes
Binary file not shown.

‎flink-core/src/test/resources/sql-date-serializer-1.13/test-data

8 Bytes
Binary file not shown.

‎flink-core/src/test/resources/sql-time-serializer-1.13/serializer-snapshot

96 Bytes
Binary file not shown.

‎flink-core/src/test/resources/sql-time-serializer-1.13/test-data

8 Bytes
Binary file not shown.

‎flink-core/src/test/resources/sql-timestamp-serializer-1.13/serializer-snapshot

106 Bytes
Binary file not shown.

‎flink-core/src/test/resources/sql-timestamp-serializer-1.13/test-data

12 Bytes
Binary file not shown.

‎flink-core/src/test/resources/string-array-serializer-1.13/serializer-snapshot

110 Bytes
Binary file not shown.

‎flink-core/src/test/resources/string-array-serializer-1.13/test-data

24 Bytes
Binary file not shown.

‎flink-core/src/test/resources/string-serializer-1.13/serializer-snapshot

94 Bytes
Binary file not shown.

‎flink-core/src/test/resources/string-serializer-1.13/test-data

+1
Original file line numberDiff line numberDiff line change
@@ -0,0 +1 @@
1+
%123456789012345678901234567890123456

‎flink-core/src/test/resources/string-value-serializer-1.13/serializer-snapshot

104 Bytes
Binary file not shown.

‎flink-core/src/test/resources/string-value-serializer-1.13/test-data

+1
Original file line numberDiff line numberDiff line change
@@ -0,0 +1 @@
1+
$123456789012345678901234567890123456

‎flink-core/src/test/resources/tuple-serializer-1.13/serializer-snapshot

401 Bytes
Binary file not shown.

‎flink-core/src/test/resources/tuple-serializer-1.13/test-data

22 Bytes
Binary file not shown.

‎flink-core/src/test/resources/value-serializer-1.13/serializer-snapshot

175 Bytes
Binary file not shown.

‎flink-core/src/test/resources/value-serializer-1.13/test-data

9 Bytes
Binary file not shown.

‎flink-formats/flink-avro/src/test/resources/generic-avro-serializer-1.13/serializer-snapshot

369 Bytes
Binary file not shown.

‎flink-formats/flink-avro/src/test/resources/generic-avro-serializer-1.13/test-data

51 Bytes
Binary file not shown.

‎flink-formats/flink-avro/src/test/resources/specific-avro-serializer-1.13/serializer-snapshot

379 Bytes
Binary file not shown.

‎flink-formats/flink-avro/src/test/resources/specific-avro-serializer-1.13/test-data

51 Bytes
Binary file not shown.

‎flink-fs-tests/src/test/java/org/apache/flink/hdfstests/ContinuousFileProcessingMigrationTest.java

+2-1
Original file line numberDiff line numberDiff line change
@@ -82,7 +82,8 @@ public static Collection<Tuple2<MigrationVersion, Long>> parameters() {
8282
Tuple2.of(MigrationVersion.v1_9, 1567499868000L),
8383
Tuple2.of(MigrationVersion.v1_10, 1594559333000L),
8484
Tuple2.of(MigrationVersion.v1_11, 1594561663000L),
85-
Tuple2.of(MigrationVersion.v1_12, 1613720148000L));
85+
Tuple2.of(MigrationVersion.v1_12, 1613720148000L),
86+
Tuple2.of(MigrationVersion.v1_13, 1627550216000L));
8687
}
8788

8889
/**

‎flink-fs-tests/src/test/resources/monitoring-function-migration-test-1627550216000-flink1.13-snapshot

324 Bytes
Binary file not shown.

‎flink-fs-tests/src/test/resources/reader-migration-test-flink1.13-snapshot

2.56 KB
Binary file not shown.

‎flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/operator/CEPMigrationTest.java

+2-1
Original file line numberDiff line numberDiff line change
@@ -79,7 +79,8 @@ public static Collection<MigrationVersion> parameters() {
7979
MigrationVersion.v1_9,
8080
MigrationVersion.v1_10,
8181
MigrationVersion.v1_11,
82-
MigrationVersion.v1_12);
82+
MigrationVersion.v1_12,
83+
MigrationVersion.v1_13);
8384
}
8485

8586
public CEPMigrationTest(MigrationVersion migrateVersion) {

‎flink-libraries/flink-cep/src/test/resources/cep-migration-after-branching-flink1.13-snapshot

5.63 KB
Binary file not shown.

‎flink-libraries/flink-cep/src/test/resources/cep-migration-conditions-flink1.13-snapshot

5.29 KB
Binary file not shown.

‎flink-libraries/flink-cep/src/test/resources/cep-migration-single-pattern-afterwards-flink1.13-snapshot

5.04 KB
Binary file not shown.

‎flink-libraries/flink-cep/src/test/resources/cep-migration-starting-new-pattern-flink1.13-snapshot

5.44 KB
Binary file not shown.

‎flink-libraries/flink-cep/src/test/resources/dewey-number-serializer-1.13/serializer-snapshot

98 Bytes
Binary file not shown.

‎flink-libraries/flink-cep/src/test/resources/dewey-number-serializer-1.13/test-data

8 Bytes
Binary file not shown.

‎flink-libraries/flink-cep/src/test/resources/event-id-serializer-1.13/serializer-snapshot

99 Bytes
Binary file not shown.

‎flink-libraries/flink-cep/src/test/resources/event-id-serializer-1.13/test-data

12 Bytes
Binary file not shown.

‎flink-libraries/flink-cep/src/test/resources/lockable-type-serializer-1.13/serializer-snapshot

188 Bytes
Binary file not shown.

‎flink-libraries/flink-cep/src/test/resources/lockable-type-serializer-1.13/test-data

10 Bytes
Binary file not shown.

‎flink-libraries/flink-cep/src/test/resources/nfa-state-serializer-1.13/serializer-snapshot

477 Bytes
Binary file not shown.

‎flink-libraries/flink-cep/src/test/resources/nfa-state-serializer-1.13/test-data

8 Bytes
Binary file not shown.

‎flink-libraries/flink-cep/src/test/resources/node-id-serializer-1.13/serializer-snapshot

211 Bytes
Binary file not shown.

‎flink-libraries/flink-cep/src/test/resources/node-id-serializer-1.13/test-data

18 Bytes
Binary file not shown.

‎flink-libraries/flink-cep/src/test/resources/shared-buffer-edge-serializer-1.13/serializer-snapshot

447 Bytes
Binary file not shown.

‎flink-libraries/flink-cep/src/test/resources/shared-buffer-edge-serializer-1.13/test-data

26 Bytes
Binary file not shown.

‎flink-libraries/flink-gelly-examples/src/test/resources/long-value-with-proper-hash-code-serializer-1.13/serializer-snapshot

162 Bytes
Binary file not shown.

‎flink-libraries/flink-gelly-examples/src/test/resources/long-value-with-proper-hash-code-serializer-1.13/test-data

8 Bytes
Binary file not shown.

‎flink-libraries/flink-gelly/src/test/resources/byte-value-array-serializer-1.13/serializer-snapshot

107 Bytes
Binary file not shown.

‎flink-libraries/flink-gelly/src/test/resources/byte-value-array-serializer-1.13/test-data

6 Bytes
Binary file not shown.

‎flink-libraries/flink-gelly/src/test/resources/char-value-array-serializer-1.13/serializer-snapshot

107 Bytes
Binary file not shown.

‎flink-libraries/flink-gelly/src/test/resources/char-value-array-serializer-1.13/test-data

10 Bytes
Binary file not shown.

‎flink-libraries/flink-gelly/src/test/resources/double-value-array-serializer-1.13/serializer-snapshot

111 Bytes
Binary file not shown.

‎flink-libraries/flink-gelly/src/test/resources/double-value-array-serializer-1.13/test-data

20 Bytes
Binary file not shown.

‎flink-libraries/flink-gelly/src/test/resources/float-value-array-serializer-1.13/serializer-snapshot

109 Bytes
Binary file not shown.

‎flink-libraries/flink-gelly/src/test/resources/float-value-array-serializer-1.13/test-data

12 Bytes
Binary file not shown.

‎flink-libraries/flink-gelly/src/test/resources/int-value-array-serializer-1.13/serializer-snapshot

105 Bytes
Binary file not shown.

‎flink-libraries/flink-gelly/src/test/resources/int-value-array-serializer-1.13/test-data

12 Bytes
Binary file not shown.

‎flink-libraries/flink-gelly/src/test/resources/long-value-array-serializer-1.13/serializer-snapshot

107 Bytes
Binary file not shown.

‎flink-libraries/flink-gelly/src/test/resources/long-value-array-serializer-1.13/test-data

20 Bytes
Binary file not shown.

‎flink-libraries/flink-gelly/src/test/resources/null-value-array-serializer-1.13/serializer-snapshot

107 Bytes
Binary file not shown.

‎flink-libraries/flink-gelly/src/test/resources/null-value-array-serializer-1.13/test-data

4 Bytes
Binary file not shown.

‎flink-libraries/flink-gelly/src/test/resources/short-value-array-serializer-1.13/serializer-snapshot

109 Bytes
Binary file not shown.

‎flink-libraries/flink-gelly/src/test/resources/short-value-array-serializer-1.13/test-data

8 Bytes
Binary file not shown.

‎flink-libraries/flink-gelly/src/test/resources/string-value-array-serializer-1.13/serializer-snapshot

111 Bytes
Binary file not shown.

‎flink-libraries/flink-gelly/src/test/resources/string-value-array-serializer-1.13/test-data

16 Bytes
Binary file not shown.

‎flink-runtime/src/test/resources/arraylist-serializer-1.13/serializer-snapshot

178 Bytes
Binary file not shown.

‎flink-runtime/src/test/resources/arraylist-serializer-1.13/test-data

17 Bytes
Binary file not shown.

‎flink-runtime/src/test/resources/java-serializer-1.13/serializer-snapshot

78 Bytes
Binary file not shown.

‎flink-runtime/src/test/resources/java-serializer-1.13/test-data

81 Bytes
Binary file not shown.

‎flink-runtime/src/test/resources/ttl-serializer-1.13/serializer-snapshot

278 Bytes
Binary file not shown.

‎flink-runtime/src/test/resources/ttl-serializer-1.13/test-data

21 Bytes
Binary file not shown.

‎flink-runtime/src/test/resources/void-namespace-serializer-1.13/serializer-snapshot

96 Bytes
Binary file not shown.

‎flink-runtime/src/test/resources/void-namespace-serializer-1.13/test-data

1 Byte
Binary file not shown.

‎flink-scala/src/test/resources/scala-case-class-serializer-1.13/serializer-snapshot

323 Bytes
Binary file not shown.

‎flink-scala/src/test/resources/scala-case-class-serializer-1.13/test-data

10 Bytes
Binary file not shown.

‎flink-scala/src/test/resources/scala-either-serializer-1.13/serializer-snapshot

270 Bytes
Binary file not shown.

‎flink-scala/src/test/resources/scala-either-serializer-1.13/test-data

13 Bytes
Binary file not shown.

‎flink-scala/src/test/resources/scala-enum-serializer-1.13/serializer-snapshot

146 Bytes
Binary file not shown.

‎flink-scala/src/test/resources/scala-enum-serializer-1.13/test-data

4 Bytes
Binary file not shown.

‎flink-scala/src/test/resources/scala-option-serializer-1.13/serializer-snapshot

186 Bytes
Binary file not shown.

‎flink-scala/src/test/resources/scala-option-serializer-1.13/test-data

1 Byte
Binary file not shown.

‎flink-scala/src/test/resources/scala-try-serializer-1.13/serializer-snapshot

672 Bytes
Binary file not shown.

‎flink-scala/src/test/resources/scala-try-serializer-1.13/test-data

3.15 KB
Binary file not shown.

‎flink-scala/src/test/resources/traversable-serializer-bitset-1.13/serializer-snapshot

286 Bytes
Binary file not shown.

‎flink-scala/src/test/resources/traversable-serializer-bitset-1.13/test-data

19 Bytes
Binary file not shown.

‎flink-scala/src/test/resources/traversable-serializer-indexedseq-1.13/serializer-snapshot

270 Bytes
Binary file not shown.

‎flink-scala/src/test/resources/traversable-serializer-indexedseq-1.13/test-data

19 Bytes
Binary file not shown.

‎flink-scala/src/test/resources/traversable-serializer-linearseq-1.13/serializer-snapshot

302 Bytes
Binary file not shown.

‎flink-scala/src/test/resources/traversable-serializer-linearseq-1.13/test-data

19 Bytes
Binary file not shown.

‎flink-scala/src/test/resources/traversable-serializer-map-1.13/serializer-snapshot

479 Bytes
Binary file not shown.

‎flink-scala/src/test/resources/traversable-serializer-map-1.13/test-data

27 Bytes
Binary file not shown.

‎flink-scala/src/test/resources/traversable-serializer-mutable-list-1.13/serializer-snapshot

322 Bytes
Binary file not shown.

‎flink-scala/src/test/resources/traversable-serializer-mutable-list-1.13/test-data

19 Bytes
Binary file not shown.

‎flink-scala/src/test/resources/traversable-serializer-seq-1.13/serializer-snapshot

256 Bytes
Binary file not shown.

‎flink-scala/src/test/resources/traversable-serializer-seq-1.13/test-data

19 Bytes
Binary file not shown.

‎flink-scala/src/test/resources/traversable-serializer-set-1.13/serializer-snapshot

256 Bytes
Binary file not shown.

‎flink-scala/src/test/resources/traversable-serializer-set-1.13/test-data

19 Bytes
Binary file not shown.

‎flink-scala/src/test/resources/traversable-serializer-with-case-class-1.13/serializer-snapshot

485 Bytes
Binary file not shown.

‎flink-scala/src/test/resources/traversable-serializer-with-case-class-1.13/test-data

27 Bytes
Binary file not shown.

‎flink-scala/src/test/resources/traversable-serializer-with-pojo-1.13/serializer-snapshot

977 Bytes
Binary file not shown.

‎flink-scala/src/test/resources/traversable-serializer-with-pojo-1.13/test-data

33 Bytes
Binary file not shown.

‎flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperatorMigrationTest.java

+2-1
Original file line numberDiff line numberDiff line change
@@ -95,7 +95,8 @@ public static Collection<MigrationVersion> parameters() {
9595
MigrationVersion.v1_9,
9696
MigrationVersion.v1_10,
9797
MigrationVersion.v1_11,
98-
MigrationVersion.v1_12);
98+
MigrationVersion.v1_12,
99+
MigrationVersion.v1_13);
99100
}
100101

101102
private static final TypeInformation<Tuple2<String, Integer>> STRING_INT_TUPLE =

‎flink-streaming-java/src/test/resources/buffer-entry-serializer-1.13/serializer-snapshot

214 Bytes
Binary file not shown.

‎flink-streaming-java/src/test/resources/buffer-entry-serializer-1.13/test-data

7 Bytes
Binary file not shown.

‎flink-streaming-java/src/test/resources/global-window-serializer-1.13/serializer-snapshot

113 Bytes
Binary file not shown.

‎flink-streaming-java/src/test/resources/global-window-serializer-1.13/test-data

1 Byte
Binary file not shown.

‎flink-streaming-java/src/test/resources/stream-element-serializer-1.13/serializer-snapshot

223 Bytes
Binary file not shown.

‎flink-streaming-java/src/test/resources/stream-element-serializer-1.13/test-data

13 Bytes
Binary file not shown.

‎flink-streaming-java/src/test/resources/time-window-serializer-1.13/serializer-snapshot

109 Bytes
Binary file not shown.

‎flink-streaming-java/src/test/resources/time-window-serializer-1.13/test-data

16 Bytes
Binary file not shown.

‎flink-streaming-java/src/test/resources/timer-serializer-1.13/serializer-snapshot

268 Bytes
Binary file not shown.

‎flink-streaming-java/src/test/resources/timer-serializer-1.13/test-data

16 Bytes
Binary file not shown.

‎flink-streaming-java/src/test/resources/two-phase-commit-sink-state-serializer-1.13/serializer-snapshot

300 Bytes
Binary file not shown.

‎flink-streaming-java/src/test/resources/two-phase-commit-sink-state-serializer-1.13/test-data

35 Bytes
Binary file not shown.

‎flink-streaming-java/src/test/resources/union-serializer-one-1.13/serializer-snapshot

288 Bytes
Binary file not shown.

‎flink-streaming-java/src/test/resources/union-serializer-one-1.13/test-data

+1
Original file line numberDiff line numberDiff line change
@@ -0,0 +1 @@
1+
flink

‎flink-streaming-java/src/test/resources/union-serializer-two-1.13/serializer-snapshot

288 Bytes
Binary file not shown.

‎flink-streaming-java/src/test/resources/union-serializer-two-1.13/test-data

9 Bytes
Binary file not shown.

‎flink-streaming-java/src/test/resources/win-op-migration-test-apply-event-time-flink1.13-snapshot

1.72 KB
Binary file not shown.

‎flink-streaming-java/src/test/resources/win-op-migration-test-apply-processing-time-flink1.13-snapshot

1.61 KB
Binary file not shown.

‎flink-streaming-java/src/test/resources/win-op-migration-test-kryo-serialized-key-flink1.13-snapshot

3.89 KB
Binary file not shown.

‎flink-streaming-java/src/test/resources/win-op-migration-test-reduce-event-time-flink1.13-snapshot

1.58 KB
Binary file not shown.

‎flink-streaming-java/src/test/resources/win-op-migration-test-reduce-processing-time-flink1.13-snapshot

1.52 KB
Binary file not shown.

‎flink-streaming-java/src/test/resources/win-op-migration-test-session-with-stateful-trigger-flink1.13-snapshot

2.61 KB
Binary file not shown.

‎flink-streaming-java/src/test/resources/win-op-migration-test-session-with-stateful-trigger-mint-flink1.13-snapshot

2.11 KB
Binary file not shown.

‎flink-table/flink-table-planner/src/test/resources/list-view-serializer-1.13/serializer-snapshot

269 Bytes
Binary file not shown.

‎flink-table/flink-table-planner/src/test/resources/list-view-serializer-1.13/test-data

16 Bytes
Binary file not shown.

‎flink-table/flink-table-planner/src/test/resources/map-view-serializer-1.13/serializer-snapshot

351 Bytes
Binary file not shown.

‎flink-table/flink-table-planner/src/test/resources/map-view-serializer-1.13/test-data

11 Bytes
Binary file not shown.

‎flink-tests/src/test/java/org/apache/flink/test/checkpointing/utils/StatefulJobSavepointMigrationITCase.java

+3-1
Original file line numberDiff line numberDiff line change
@@ -95,7 +95,9 @@ public static Collection<Tuple2<MigrationVersion, String>> parameters() {
9595
Tuple2.of(MigrationVersion.v1_11, StateBackendLoader.MEMORY_STATE_BACKEND_NAME),
9696
Tuple2.of(MigrationVersion.v1_11, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME),
9797
Tuple2.of(MigrationVersion.v1_12, StateBackendLoader.MEMORY_STATE_BACKEND_NAME),
98-
Tuple2.of(MigrationVersion.v1_12, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME));
98+
Tuple2.of(MigrationVersion.v1_12, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME),
99+
Tuple2.of(MigrationVersion.v1_13, StateBackendLoader.MEMORY_STATE_BACKEND_NAME),
100+
Tuple2.of(MigrationVersion.v1_13, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME));
99101
}
100102

101103
private final MigrationVersion testMigrateVersion;

‎flink-tests/src/test/java/org/apache/flink/test/checkpointing/utils/StatefulJobWBroadcastStateMigrationITCase.java

+3-1
Original file line numberDiff line numberDiff line change
@@ -79,7 +79,9 @@ public static Collection<Tuple2<MigrationVersion, String>> parameters() {
7979
Tuple2.of(MigrationVersion.v1_11, StateBackendLoader.MEMORY_STATE_BACKEND_NAME),
8080
Tuple2.of(MigrationVersion.v1_11, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME),
8181
Tuple2.of(MigrationVersion.v1_12, StateBackendLoader.MEMORY_STATE_BACKEND_NAME),
82-
Tuple2.of(MigrationVersion.v1_12, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME));
82+
Tuple2.of(MigrationVersion.v1_12, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME),
83+
Tuple2.of(MigrationVersion.v1_13, StateBackendLoader.MEMORY_STATE_BACKEND_NAME),
84+
Tuple2.of(MigrationVersion.v1_13, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME));
8385
}
8486

8587
private final MigrationVersion testMigrateVersion;

‎flink-tests/src/test/java/org/apache/flink/test/migration/TypeSerializerSnapshotMigrationITCase.java

+3-1
Original file line numberDiff line numberDiff line change
@@ -97,7 +97,9 @@ public static Collection<Tuple2<MigrationVersion, String>> parameters() {
9797
Tuple2.of(MigrationVersion.v1_11, StateBackendLoader.MEMORY_STATE_BACKEND_NAME),
9898
Tuple2.of(MigrationVersion.v1_11, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME),
9999
Tuple2.of(MigrationVersion.v1_12, StateBackendLoader.MEMORY_STATE_BACKEND_NAME),
100-
Tuple2.of(MigrationVersion.v1_12, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME));
100+
Tuple2.of(MigrationVersion.v1_12, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME),
101+
Tuple2.of(MigrationVersion.v1_13, StateBackendLoader.MEMORY_STATE_BACKEND_NAME),
102+
Tuple2.of(MigrationVersion.v1_13, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME));
101103
}
102104

103105
private final MigrationVersion testMigrateVersion;

‎flink-tests/src/test/java/org/apache/flink/test/state/operator/restore/keyed/AbstractKeyedOperatorRestoreTestBase.java

+2-1
Original file line numberDiff line numberDiff line change
@@ -49,7 +49,8 @@ public static Collection<MigrationVersion> parameters() {
4949
MigrationVersion.v1_9,
5050
MigrationVersion.v1_10,
5151
MigrationVersion.v1_11,
52-
MigrationVersion.v1_12);
52+
MigrationVersion.v1_12,
53+
MigrationVersion.v1_13);
5354
}
5455

5556
public AbstractKeyedOperatorRestoreTestBase(MigrationVersion migrationVersion) {

‎flink-tests/src/test/java/org/apache/flink/test/state/operator/restore/unkeyed/AbstractNonKeyedOperatorRestoreTestBase.java

+2-1
Original file line numberDiff line numberDiff line change
@@ -56,7 +56,8 @@ public static Collection<MigrationVersion> parameters() {
5656
MigrationVersion.v1_9,
5757
MigrationVersion.v1_10,
5858
MigrationVersion.v1_11,
59-
MigrationVersion.v1_12);
59+
MigrationVersion.v1_12,
60+
MigrationVersion.v1_13);
6061
}
6162

6263
protected AbstractNonKeyedOperatorRestoreTestBase(MigrationVersion migrationVersion) {

‎flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.13-rocksdb-savepoint/_metadata

13.5 KB
Binary file not shown.

‎flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.13-savepoint/_metadata

13.5 KB
Binary file not shown.

‎flink-tests/src/test/resources/new-stateful-udf-migration-itcase-flink1.13-rocksdb-savepoint/_metadata

16.9 KB
Binary file not shown.

‎flink-tests/src/test/resources/new-stateful-udf-migration-itcase-flink1.13-savepoint/_metadata

16.9 KB
Binary file not shown.

‎flink-tests/src/test/resources/operatorstate/complexKeyed-flink1.13/_metadata

13.4 KB
Binary file not shown.

‎flink-tests/src/test/resources/operatorstate/nonKeyed-flink1.13/_metadata

3.61 KB
Binary file not shown.

‎flink-tests/src/test/resources/stateful-scala-udf-migration-itcase-flink1.13-jobmanager-savepoint/_metadata

41 KB
Binary file not shown.

‎flink-tests/src/test/resources/stateful-scala-udf-migration-itcase-flink1.13-rocksdb-savepoint/_metadata

41 KB
Binary file not shown.

‎flink-tests/src/test/resources/stateful-scala-with-broadcast-udf-migration-itcase-flink1.13-jobmanager-savepoint/_metadata

52.5 KB
Binary file not shown.

‎flink-tests/src/test/resources/stateful-scala-with-broadcast-udf-migration-itcase-flink1.13-rocksdb-savepoint/_metadata

52.5 KB
Binary file not shown.

‎flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.13-rocksdb-savepoint/_metadata

1.24 KB
Binary file not shown.

‎flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.13-savepoint/_metadata

1.24 KB
Binary file not shown.

‎flink-tests/src/test/scala/org/apache/flink/api/scala/migration/StatefulJobSavepointMigrationITCase.scala

+3-1
Original file line numberDiff line numberDiff line change
@@ -68,7 +68,9 @@ object StatefulJobSavepointMigrationITCase {
6868
(MigrationVersion.v1_11, StateBackendLoader.MEMORY_STATE_BACKEND_NAME),
6969
(MigrationVersion.v1_11, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME),
7070
(MigrationVersion.v1_12, StateBackendLoader.MEMORY_STATE_BACKEND_NAME),
71-
(MigrationVersion.v1_12, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME))
71+
(MigrationVersion.v1_12, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME),
72+
(MigrationVersion.v1_13, StateBackendLoader.MEMORY_STATE_BACKEND_NAME),
73+
(MigrationVersion.v1_13, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME))
7274
}
7375

7476
// TODO to generate savepoints for a specific Flink version / backend type,

‎flink-tests/src/test/scala/org/apache/flink/api/scala/migration/StatefulJobWBroadcastStateMigrationITCase.scala

+3-1
Original file line numberDiff line numberDiff line change
@@ -68,7 +68,9 @@ object StatefulJobWBroadcastStateMigrationITCase {
6868
(MigrationVersion.v1_11, StateBackendLoader.MEMORY_STATE_BACKEND_NAME),
6969
(MigrationVersion.v1_11, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME),
7070
(MigrationVersion.v1_12, StateBackendLoader.MEMORY_STATE_BACKEND_NAME),
71-
(MigrationVersion.v1_12, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME))
71+
(MigrationVersion.v1_12, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME),
72+
(MigrationVersion.v1_13, StateBackendLoader.MEMORY_STATE_BACKEND_NAME),
73+
(MigrationVersion.v1_13, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME))
7274
}
7375

7476
// TODO to generate savepoints for a specific Flink version / backend type,

0 commit comments

Comments
 (0)