[
https://issues.apache.org/jira/browse/FLINK-10139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16586101#comment-16586101
]
ASF GitHub Bot commented on FLINK-10139:
----------------------------------------
zentol closed pull request #6582: [FLINK-10139][tests] Update compatibility
tests for 1.6
URL: https://github.com/apache/flink/pull/6582
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance:
As this is a foreign pull request (from a fork), the diff is supplied
below (as it won't show otherwise due to GitHub magic):
diff --git
a/flink-connectors/flink-connector-filesystem/src/test/java/org/apache/flink/streaming/connectors/fs/bucketing/BucketingSinkMigrationTest.java
b/flink-connectors/flink-connector-filesystem/src/test/java/org/apache/flink/streaming/connectors/fs/bucketing/BucketingSinkMigrationTest.java
index 38cc9149ee2..981a529ddd2 100644
---
a/flink-connectors/flink-connector-filesystem/src/test/java/org/apache/flink/streaming/connectors/fs/bucketing/BucketingSinkMigrationTest.java
+++
b/flink-connectors/flink-connector-filesystem/src/test/java/org/apache/flink/streaming/connectors/fs/bucketing/BucketingSinkMigrationTest.java
@@ -89,7 +89,8 @@ public static void verifyOS() {
Tuple2.of(MigrationVersion.v1_2,
"/var/folders/v_/ry2wp5fx0y7c1rvr41xy9_700000gn/T/junit9160378385359106772/junit479663758539998903/1970-01-01--01/part-0-"),
Tuple2.of(MigrationVersion.v1_3,
"/var/folders/tv/b_1d8fvx23dgk1_xs8db_95h0000gn/T/junit4273542175898623023/junit3801102997056424640/1970-01-01--01/part-0-"),
Tuple2.of(MigrationVersion.v1_4,
"/var/folders/tv/b_1d8fvx23dgk1_xs8db_95h0000gn/T/junit3198043255809479705/junit8947526563966405708/1970-01-01--01/part-0-"),
- Tuple2.of(MigrationVersion.v1_5,
"/tmp/junit4927100426019463155/junit2465610012100182280/1970-01-01--00/part-0-"));
+ Tuple2.of(MigrationVersion.v1_5,
"/tmp/junit4927100426019463155/junit2465610012100182280/1970-01-01--00/part-0-"),
+ Tuple2.of(MigrationVersion.v1_6,
"/tmp/junit3459711376354834545/junit5114611885650086135/1970-01-01--00/part-0-"));
}
private final MigrationVersion testMigrateVersion;
diff --git
a/flink-connectors/flink-connector-filesystem/src/test/resources/bucketing-sink-migration-test-flink1.6-snapshot
b/flink-connectors/flink-connector-filesystem/src/test/resources/bucketing-sink-migration-test-flink1.6-snapshot
new file mode 100644
index 00000000000..6c35ed9f776
Binary files /dev/null and
b/flink-connectors/flink-connector-filesystem/src/test/resources/bucketing-sink-migration-test-flink1.6-snapshot
differ
diff --git
a/flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBaseMigrationTest.java
b/flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBaseMigrationTest.java
index 6776cd5eb22..74770d04549 100644
---
a/flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBaseMigrationTest.java
+++
b/flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBaseMigrationTest.java
@@ -93,7 +93,12 @@
@Parameterized.Parameters(name = "Migration Savepoint: {0}")
public static Collection<MigrationVersion> parameters () {
- return Arrays.asList(MigrationVersion.v1_2,
MigrationVersion.v1_3, MigrationVersion.v1_4, MigrationVersion.v1_5);
+ return Arrays.asList(
+ MigrationVersion.v1_2,
+ MigrationVersion.v1_3,
+ MigrationVersion.v1_4,
+ MigrationVersion.v1_5,
+ MigrationVersion.v1_6);
}
public FlinkKafkaConsumerBaseMigrationTest(MigrationVersion
testMigrateVersion) {
diff --git
a/flink-connectors/flink-connector-kafka-base/src/test/resources/kafka-consumer-migration-test-flink1.6-empty-state-snapshot
b/flink-connectors/flink-connector-kafka-base/src/test/resources/kafka-consumer-migration-test-flink1.6-empty-state-snapshot
new file mode 100644
index 00000000000..1b039fe719e
Binary files /dev/null and
b/flink-connectors/flink-connector-kafka-base/src/test/resources/kafka-consumer-migration-test-flink1.6-empty-state-snapshot
differ
diff --git
a/flink-connectors/flink-connector-kafka-base/src/test/resources/kafka-consumer-migration-test-flink1.6-snapshot
b/flink-connectors/flink-connector-kafka-base/src/test/resources/kafka-consumer-migration-test-flink1.6-snapshot
new file mode 100644
index 00000000000..ea2e09c4bb6
Binary files /dev/null and
b/flink-connectors/flink-connector-kafka-base/src/test/resources/kafka-consumer-migration-test-flink1.6-snapshot
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 615ec2349c5..f4a2c9f1ef9 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
@@ -79,7 +79,8 @@
Tuple2.of(MigrationVersion.v1_2, 1493116191000L),
Tuple2.of(MigrationVersion.v1_3, 1496532000000L),
Tuple2.of(MigrationVersion.v1_4, 1516897628000L),
- Tuple2.of(MigrationVersion.v1_5, 1533639934000L));
+ Tuple2.of(MigrationVersion.v1_5, 1533639934000L),
+ Tuple2.of(MigrationVersion.v1_6, 1534696817000L));
}
/**
diff --git
a/flink-fs-tests/src/test/resources/monitoring-function-migration-test-1534696817000-flink1.6-snapshot
b/flink-fs-tests/src/test/resources/monitoring-function-migration-test-1534696817000-flink1.6-snapshot
new file mode 100644
index 00000000000..7220dbc7ef4
Binary files /dev/null and
b/flink-fs-tests/src/test/resources/monitoring-function-migration-test-1534696817000-flink1.6-snapshot
differ
diff --git
a/flink-fs-tests/src/test/resources/reader-migration-test-flink1.6-snapshot
b/flink-fs-tests/src/test/resources/reader-migration-test-flink1.6-snapshot
new file mode 100644
index 00000000000..3d8fc68ceb2
Binary files /dev/null and
b/flink-fs-tests/src/test/resources/reader-migration-test-flink1.6-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 6c7543a47c3..bc8ef25a5a3 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
@@ -71,7 +71,11 @@
@Parameterized.Parameters(name = "Migration Savepoint: {0}")
public static Collection<MigrationVersion> parameters () {
- return Arrays.asList(MigrationVersion.v1_3,
MigrationVersion.v1_4, MigrationVersion.v1_5);
+ return Arrays.asList(
+ MigrationVersion.v1_3,
+ MigrationVersion.v1_4,
+ MigrationVersion.v1_5,
+ MigrationVersion.v1_6);
}
public CEPMigrationTest(MigrationVersion migrateVersion) {
diff --git
a/flink-libraries/flink-cep/src/test/resources/cep-migration-after-branching-flink1.6-snapshot
b/flink-libraries/flink-cep/src/test/resources/cep-migration-after-branching-flink1.6-snapshot
new file mode 100644
index 00000000000..17b7da4b077
Binary files /dev/null and
b/flink-libraries/flink-cep/src/test/resources/cep-migration-after-branching-flink1.6-snapshot
differ
diff --git
a/flink-libraries/flink-cep/src/test/resources/cep-migration-conditions-flink1.6-snapshot
b/flink-libraries/flink-cep/src/test/resources/cep-migration-conditions-flink1.6-snapshot
new file mode 100644
index 00000000000..2c92eb57061
Binary files /dev/null and
b/flink-libraries/flink-cep/src/test/resources/cep-migration-conditions-flink1.6-snapshot
differ
diff --git
a/flink-libraries/flink-cep/src/test/resources/cep-migration-single-pattern-afterwards-flink1.6-snapshot
b/flink-libraries/flink-cep/src/test/resources/cep-migration-single-pattern-afterwards-flink1.6-snapshot
new file mode 100644
index 00000000000..396d617b27e
Binary files /dev/null and
b/flink-libraries/flink-cep/src/test/resources/cep-migration-single-pattern-afterwards-flink1.6-snapshot
differ
diff --git
a/flink-libraries/flink-cep/src/test/resources/cep-migration-starting-new-pattern-flink1.6-snapshot
b/flink-libraries/flink-cep/src/test/resources/cep-migration-starting-new-pattern-flink1.6-snapshot
new file mode 100644
index 00000000000..4cc717b46a4
Binary files /dev/null and
b/flink-libraries/flink-cep/src/test/resources/cep-migration-starting-new-pattern-flink1.6-snapshot
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 44fd3745242..c27d6418ae4 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
@@ -86,7 +86,12 @@
@Parameterized.Parameters(name = "Migration Savepoint: {0}")
public static Collection<MigrationVersion> parameters () {
- return Arrays.asList(MigrationVersion.v1_2,
MigrationVersion.v1_3, MigrationVersion.v1_4, MigrationVersion.v1_5);
+ return Arrays.asList(
+ MigrationVersion.v1_2,
+ MigrationVersion.v1_3,
+ MigrationVersion.v1_4,
+ MigrationVersion.v1_5,
+ MigrationVersion.v1_6);
}
private static final TypeInformation<Tuple2<String, Integer>>
STRING_INT_TUPLE =
diff --git
a/flink-streaming-java/src/test/resources/win-op-migration-test-apply-event-time-flink1.6-snapshot
b/flink-streaming-java/src/test/resources/win-op-migration-test-apply-event-time-flink1.6-snapshot
new file mode 100644
index 00000000000..2bef6a31911
Binary files /dev/null and
b/flink-streaming-java/src/test/resources/win-op-migration-test-apply-event-time-flink1.6-snapshot
differ
diff --git
a/flink-streaming-java/src/test/resources/win-op-migration-test-apply-processing-time-flink1.6-snapshot
b/flink-streaming-java/src/test/resources/win-op-migration-test-apply-processing-time-flink1.6-snapshot
new file mode 100644
index 00000000000..5528efd2a7d
Binary files /dev/null and
b/flink-streaming-java/src/test/resources/win-op-migration-test-apply-processing-time-flink1.6-snapshot
differ
diff --git
a/flink-streaming-java/src/test/resources/win-op-migration-test-kryo-serialized-key-flink1.6-snapshot
b/flink-streaming-java/src/test/resources/win-op-migration-test-kryo-serialized-key-flink1.6-snapshot
new file mode 100644
index 00000000000..03c4cffd6a1
Binary files /dev/null and
b/flink-streaming-java/src/test/resources/win-op-migration-test-kryo-serialized-key-flink1.6-snapshot
differ
diff --git
a/flink-streaming-java/src/test/resources/win-op-migration-test-reduce-event-time-flink1.6-snapshot
b/flink-streaming-java/src/test/resources/win-op-migration-test-reduce-event-time-flink1.6-snapshot
new file mode 100644
index 00000000000..bdc37b7593f
Binary files /dev/null and
b/flink-streaming-java/src/test/resources/win-op-migration-test-reduce-event-time-flink1.6-snapshot
differ
diff --git
a/flink-streaming-java/src/test/resources/win-op-migration-test-reduce-processing-time-flink1.6-snapshot
b/flink-streaming-java/src/test/resources/win-op-migration-test-reduce-processing-time-flink1.6-snapshot
new file mode 100644
index 00000000000..1e339ea935e
Binary files /dev/null and
b/flink-streaming-java/src/test/resources/win-op-migration-test-reduce-processing-time-flink1.6-snapshot
differ
diff --git
a/flink-streaming-java/src/test/resources/win-op-migration-test-session-with-stateful-trigger-flink1.6-snapshot
b/flink-streaming-java/src/test/resources/win-op-migration-test-session-with-stateful-trigger-flink1.6-snapshot
new file mode 100644
index 00000000000..67f43e4792a
Binary files /dev/null and
b/flink-streaming-java/src/test/resources/win-op-migration-test-session-with-stateful-trigger-flink1.6-snapshot
differ
diff --git
a/flink-streaming-java/src/test/resources/win-op-migration-test-session-with-stateful-trigger-mint-flink1.6-snapshot
b/flink-streaming-java/src/test/resources/win-op-migration-test-session-with-stateful-trigger-mint-flink1.6-snapshot
new file mode 100644
index 00000000000..1f0a31d1d02
Binary files /dev/null and
b/flink-streaming-java/src/test/resources/win-op-migration-test-session-with-stateful-trigger-mint-flink1.6-snapshot
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 e8a47b06a28..fd107058b8a 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
@@ -80,7 +80,9 @@
Tuple2.of(MigrationVersion.v1_4,
StateBackendLoader.MEMORY_STATE_BACKEND_NAME),
Tuple2.of(MigrationVersion.v1_4,
StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME),
Tuple2.of(MigrationVersion.v1_5,
StateBackendLoader.MEMORY_STATE_BACKEND_NAME),
- Tuple2.of(MigrationVersion.v1_5,
StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME));
+ Tuple2.of(MigrationVersion.v1_5,
StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME),
+ Tuple2.of(MigrationVersion.v1_6,
StateBackendLoader.MEMORY_STATE_BACKEND_NAME),
+ Tuple2.of(MigrationVersion.v1_6,
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 0e582694362..1920d331d54 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
@@ -41,7 +41,12 @@
@Parameterized.Parameters(name = "Migrate Savepoint: {0}")
public static Collection<MigrationVersion> parameters () {
- return Arrays.asList(MigrationVersion.v1_2,
MigrationVersion.v1_3, MigrationVersion.v1_4, MigrationVersion.v1_5);
+ return Arrays.asList(
+ MigrationVersion.v1_2,
+ MigrationVersion.v1_3,
+ MigrationVersion.v1_4,
+ MigrationVersion.v1_5,
+ MigrationVersion.v1_6);
}
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 74b2086c842..09c70372926 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
@@ -47,7 +47,12 @@
@Parameterized.Parameters(name = "Migrate Savepoint: {0}")
public static Collection<MigrationVersion> parameters () {
- return Arrays.asList(MigrationVersion.v1_2,
MigrationVersion.v1_3, MigrationVersion.v1_4, MigrationVersion.v1_5);
+ return Arrays.asList(
+ MigrationVersion.v1_2,
+ MigrationVersion.v1_3,
+ MigrationVersion.v1_4,
+ MigrationVersion.v1_5,
+ MigrationVersion.v1_6);
}
protected AbstractNonKeyedOperatorRestoreTestBase(MigrationVersion
migrationVersion) {
diff --git
a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.6-rocksdb-savepoint/_metadata
b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.6-rocksdb-savepoint/_metadata
index 86b2f18f549..9e2b08654b2 100644
Binary files
a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.6-rocksdb-savepoint/_metadata
and
b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.6-rocksdb-savepoint/_metadata
differ
diff --git
a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.6-savepoint/_metadata
b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.6-savepoint/_metadata
index 627b3850c83..cceb5bf7f89 100644
Binary files
a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.6-savepoint/_metadata
and
b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.6-savepoint/_metadata
differ
diff --git
a/flink-tests/src/test/resources/new-stateful-udf-migration-itcase-flink1.6-rocksdb-savepoint/_metadata
b/flink-tests/src/test/resources/new-stateful-udf-migration-itcase-flink1.6-rocksdb-savepoint/_metadata
new file mode 100644
index 00000000000..2503d827786
Binary files /dev/null and
b/flink-tests/src/test/resources/new-stateful-udf-migration-itcase-flink1.6-rocksdb-savepoint/_metadata
differ
diff --git
a/flink-tests/src/test/resources/new-stateful-udf-migration-itcase-flink1.6-savepoint/_metadata
b/flink-tests/src/test/resources/new-stateful-udf-migration-itcase-flink1.6-savepoint/_metadata
new file mode 100644
index 00000000000..58a43aff143
Binary files /dev/null and
b/flink-tests/src/test/resources/new-stateful-udf-migration-itcase-flink1.6-savepoint/_metadata
differ
diff --git
a/flink-tests/src/test/resources/operatorstate/complexKeyed-flink1.6/_metadata
b/flink-tests/src/test/resources/operatorstate/complexKeyed-flink1.6/_metadata
new file mode 100644
index 00000000000..446f82977cd
Binary files /dev/null and
b/flink-tests/src/test/resources/operatorstate/complexKeyed-flink1.6/_metadata
differ
diff --git
a/flink-tests/src/test/resources/operatorstate/nonKeyed-flink1.6/_metadata
b/flink-tests/src/test/resources/operatorstate/nonKeyed-flink1.6/_metadata
new file mode 100644
index 00000000000..a78ae0745ff
Binary files /dev/null and
b/flink-tests/src/test/resources/operatorstate/nonKeyed-flink1.6/_metadata
differ
diff --git
a/flink-tests/src/test/resources/stateful-scala-with-broadcast2.11-udf-migration-itcase-flink1.6-jobmanager-savepoint/_metadata
b/flink-tests/src/test/resources/stateful-scala-with-broadcast2.11-udf-migration-itcase-flink1.6-jobmanager-savepoint/_metadata
index 04932e6bdce..b64e8107b88 100644
Binary files
a/flink-tests/src/test/resources/stateful-scala-with-broadcast2.11-udf-migration-itcase-flink1.6-jobmanager-savepoint/_metadata
and
b/flink-tests/src/test/resources/stateful-scala-with-broadcast2.11-udf-migration-itcase-flink1.6-jobmanager-savepoint/_metadata
differ
diff --git
a/flink-tests/src/test/resources/stateful-scala-with-broadcast2.11-udf-migration-itcase-flink1.6-rocksdb-savepoint/_metadata
b/flink-tests/src/test/resources/stateful-scala-with-broadcast2.11-udf-migration-itcase-flink1.6-rocksdb-savepoint/_metadata
index 2323742e91b..59bebc9ef58 100644
Binary files
a/flink-tests/src/test/resources/stateful-scala-with-broadcast2.11-udf-migration-itcase-flink1.6-rocksdb-savepoint/_metadata
and
b/flink-tests/src/test/resources/stateful-scala-with-broadcast2.11-udf-migration-itcase-flink1.6-rocksdb-savepoint/_metadata
differ
diff --git
a/flink-tests/src/test/resources/stateful-scala2.11-udf-migration-itcase-flink1.6-jobmanager-savepoint/_metadata
b/flink-tests/src/test/resources/stateful-scala2.11-udf-migration-itcase-flink1.6-jobmanager-savepoint/_metadata
new file mode 100644
index 00000000000..55243f3e5ec
Binary files /dev/null and
b/flink-tests/src/test/resources/stateful-scala2.11-udf-migration-itcase-flink1.6-jobmanager-savepoint/_metadata
differ
diff --git
a/flink-tests/src/test/resources/stateful-scala2.11-udf-migration-itcase-flink1.6-rocksdb-savepoint/_metadata
b/flink-tests/src/test/resources/stateful-scala2.11-udf-migration-itcase-flink1.6-rocksdb-savepoint/_metadata
new file mode 100644
index 00000000000..defe3b17cfe
Binary files /dev/null and
b/flink-tests/src/test/resources/stateful-scala2.11-udf-migration-itcase-flink1.6-rocksdb-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 cba31d3cbea..557f54aa168 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
@@ -56,7 +56,9 @@ object StatefulJobSavepointMigrationITCase {
(MigrationVersion.v1_3, StateBackendLoader.MEMORY_STATE_BACKEND_NAME),
(MigrationVersion.v1_3, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME),
(MigrationVersion.v1_4, StateBackendLoader.MEMORY_STATE_BACKEND_NAME),
- (MigrationVersion.v1_4, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME))
+ (MigrationVersion.v1_4, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME),
+ (MigrationVersion.v1_6, StateBackendLoader.MEMORY_STATE_BACKEND_NAME),
+ (MigrationVersion.v1_6, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME))
}
// TODO to generate savepoints for a specific Flink version / backend type,
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
> Update migration tests for 1.6
> ------------------------------
>
> Key: FLINK-10139
> URL: https://issues.apache.org/jira/browse/FLINK-10139
> Project: Flink
> Issue Type: Test
> Components: Tests
> Affects Versions: 1.7.0
> Reporter: Chesnay Schepler
> Assignee: Chesnay Schepler
> Priority: Major
> Labels: pull-request-available
> Fix For: 1.7.0
>
>
> Similar to FLINK-10084 we have to update the migration tests for 1.6.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
