[FLINK-13621][Tests] Update ContinuousFileProcessingMigrationTest to …

…restore from 1.9 savepoint This closes apache#9600.
spotify · Sep 6, 2019 · bee0967 · bee0967
1 parent dc9e449
commit bee0967
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
@@ -81,7 +81,8 @@ public static Collection<Tuple2<MigrationVersion, Long>> parameters () {
  Tuple2.of(MigrationVersion.v1_5, 1533639934000L),
  Tuple2.of(MigrationVersion.v1_6, 1534696817000L),
  Tuple2.of(MigrationVersion.v1_7, 1544024599000L),
- Tuple2.of(MigrationVersion.v1_8, 1555215710000L));
+ Tuple2.of(MigrationVersion.v1_8, 1555215710000L),
+ Tuple2.of(MigrationVersion.v1_9, 1567499868000L));
  }
 
  /**

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