[release] Upgrade current version to 1.16 for FlinkKinesisConsumerMig…

…rationTest and create snapshots
lovepoem · Oct 31, 2022 · bb4127d · bb4127d
1 parent 2c9c9ad
commit bb4127d
Show file tree

Hide file tree

Showing 3 changed files with 2 additions and 2 deletions.
diff --git a/...java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumerMigrationTest.java b/...java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumerMigrationTest.java
@@ -106,15 +106,15 @@ public static Collection<FlinkVersion> parameters() {
                 FlinkVersion.v1_12,
                 FlinkVersion.v1_13,
                 FlinkVersion.v1_14,
-                FlinkVersion.v1_15);
+                FlinkVersion.v1_15,
+                FlinkVersion.v1_16);
     }
 
     public FlinkKinesisConsumerMigrationTest(FlinkVersion testMigrateVersion) {
         this.testMigrateVersion = testMigrateVersion;
     }
 
     /** Manually run this to write binary snapshot data. */
-    @Ignore
     @Test
     public void writeSnapshot() throws Exception {
         writeSnapshot(

diff --git a/...ector-kinesis/src/test/resources/kinesis-consumer-migration-test-flink1.16-empty-snapshot b/...ector-kinesis/src/test/resources/kinesis-consumer-migration-test-flink1.16-empty-snapshot
diff --git a/...k-connector-kinesis/src/test/resources/kinesis-consumer-migration-test-flink1.16-snapshot b/...k-connector-kinesis/src/test/resources/kinesis-consumer-migration-test-flink1.16-snapshot