[FLINK-13618] Update FlinkKafkaConsumerBaseMigrationTest to restore f…

…rom 1.9 savepoint This closes apache#9594.
silenceland · Sep 2, 2019 · c83ba10 · c83ba10
1 parent 6094a52
commit c83ba10
Show file tree

Hide file tree

Showing 3 changed files with 2 additions and 1 deletion.
diff --git a/...java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBaseMigrationTest.java b/...java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBaseMigrationTest.java
@@ -106,7 +106,8 @@ public static Collection<MigrationVersion> parameters () {
 			MigrationVersion.v1_5,
 			MigrationVersion.v1_6,
 			MigrationVersion.v1_7,
-			MigrationVersion.v1_8);
+			MigrationVersion.v1_8,
+			MigrationVersion.v1_9);
 	}
 
 	public FlinkKafkaConsumerBaseMigrationTest(MigrationVersion testMigrateVersion) {

diff --git a/...kafka-base/src/test/resources/kafka-consumer-migration-test-flink1.9-empty-state-snapshot b/...kafka-base/src/test/resources/kafka-consumer-migration-test-flink1.9-empty-state-snapshot
diff --git a/...k-connector-kafka-base/src/test/resources/kafka-consumer-migration-test-flink1.9-snapshot b/...k-connector-kafka-base/src/test/resources/kafka-consumer-migration-test-flink1.9-snapshot