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 d29ded567df7a..615ec2349c511 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 @@ -78,7 +78,8 @@ public static Collection> parameters () { return Arrays.asList( Tuple2.of(MigrationVersion.v1_2, 1493116191000L), Tuple2.of(MigrationVersion.v1_3, 1496532000000L), - Tuple2.of(MigrationVersion.v1_4, 1516897628000L)); + Tuple2.of(MigrationVersion.v1_4, 1516897628000L), + Tuple2.of(MigrationVersion.v1_5, 1533639934000L)); } /** diff --git a/flink-fs-tests/src/test/resources/monitoring-function-migration-test-1533639934000-flink1.5-snapshot b/flink-fs-tests/src/test/resources/monitoring-function-migration-test-1533639934000-flink1.5-snapshot new file mode 100644 index 0000000000000..d3959b4ebbb28 Binary files /dev/null and b/flink-fs-tests/src/test/resources/monitoring-function-migration-test-1533639934000-flink1.5-snapshot differ diff --git a/flink-fs-tests/src/test/resources/reader-migration-test-flink1.5-snapshot b/flink-fs-tests/src/test/resources/reader-migration-test-flink1.5-snapshot new file mode 100644 index 0000000000000..6b56e8a5beb0a Binary files /dev/null and b/flink-fs-tests/src/test/resources/reader-migration-test-flink1.5-snapshot differ