[FLINK-8472] [fs, test] Extend ContinuousFileProcessingMigrationTest …

…for Flink 1.4
arganzheng · Feb 6, 2018 · c100936 · c100936
1 parent 535d139
commit c100936
Show file tree

Hide file tree

Showing 3 changed files with 2 additions and 1 deletion.
diff --git a/...tests/src/test/java/org/apache/flink/hdfstests/ContinuousFileProcessingMigrationTest.java b/...tests/src/test/java/org/apache/flink/hdfstests/ContinuousFileProcessingMigrationTest.java
@@ -77,7 +77,8 @@ public class ContinuousFileProcessingMigrationTest {
 	public static Collection<Tuple2<MigrationVersion, Long>> parameters () {
 		return Arrays.asList(
 			Tuple2.of(MigrationVersion.v1_2, 1493116191000L),
-			Tuple2.of(MigrationVersion.v1_3, 1496532000000L));
+			Tuple2.of(MigrationVersion.v1_3, 1496532000000L),
+			Tuple2.of(MigrationVersion.v1_4, 1516897628000L));
 	}
 
 	/**

diff --git a/...sts/src/test/resources/monitoring-function-migration-test-1516897628000-flink1.4-snapshot b/...sts/src/test/resources/monitoring-function-migration-test-1516897628000-flink1.4-snapshot
diff --git a/flink-fs-tests/src/test/resources/reader-migration-test-flink1.4-snapshot b/flink-fs-tests/src/test/resources/reader-migration-test-flink1.4-snapshot