[FLINK-8472] [kinesis, test] Extend FlinkKinesisConsumerMigrationTest…

… for Flink 1.4
Jin-H · Feb 6, 2018 · e609f81 · e609f81
1 parent 74daaef
commit e609f81
Show file tree

Hide file tree

Showing 3 changed files with 1 addition and 1 deletion.
diff --git a/...java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumerMigrationTest.java b/...java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumerMigrationTest.java
@@ -97,7 +97,7 @@ public class FlinkKinesisConsumerMigrationTest {
 
 	@Parameterized.Parameters(name = "Migration Savepoint: {0}")
 	public static Collection<MigrationVersion> parameters () {
-		return Arrays.asList(MigrationVersion.v1_3);
+		return Arrays.asList(MigrationVersion.v1_3, MigrationVersion.v1_4);
 	}
 
 	public FlinkKinesisConsumerMigrationTest(MigrationVersion testMigrateVersion) {

diff --git a/...nector-kinesis/src/test/resources/kinesis-consumer-migration-test-flink1.4-empty-snapshot b/...nector-kinesis/src/test/resources/kinesis-consumer-migration-test-flink1.4-empty-snapshot
diff --git a/...nk-connector-kinesis/src/test/resources/kinesis-consumer-migration-test-flink1.4-snapshot b/...nk-connector-kinesis/src/test/resources/kinesis-consumer-migration-test-flink1.4-snapshot