[flink] 04/14: [release] Upgrade current version to 1.16 for FlinkKinesisConsumerMigrationTest and create snapshots

[hxb]

This is an automated email from the ASF dual-hosted git repository.

hxb pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git

commit bb4127d079598833779b07edcd39db31c1ffbedd
Author: huangxingbo <h...@apache.org>
AuthorDate: Thu Oct 27 16:40:48 2022 +0800

    [release] Upgrade current version to 1.16 for 
FlinkKinesisConsumerMigrationTest and create snapshots
---
 .../kinesis/FlinkKinesisConsumerMigrationTest.java       |   4 ++--
 ...esis-consumer-migration-test-flink1.16-empty-snapshot | Bin 0 -> 2870 bytes
 .../kinesis-consumer-migration-test-flink1.16-snapshot   | Bin 0 -> 2938 bytes
 3 files changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumerMigrationTest.java
 
b/flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumerMigrationTest.java
index 0099f48a648..1957782bb2a 100644
--- 
a/flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumerMigrationTest.java
+++ 
b/flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumerMigrationTest.java
@@ -106,7 +106,8 @@ public class FlinkKinesisConsumerMigrationTest {
                 FlinkVersion.v1_12,
                 FlinkVersion.v1_13,
                 FlinkVersion.v1_14,
-                FlinkVersion.v1_15);
+                FlinkVersion.v1_15,
+                FlinkVersion.v1_16);
     }
 
     public FlinkKinesisConsumerMigrationTest(FlinkVersion testMigrateVersion) {
@@ -114,7 +115,6 @@ public class FlinkKinesisConsumerMigrationTest {
     }
 
     /** Manually run this to write binary snapshot data. */
-    @Ignore
     @Test
     public void writeSnapshot() throws Exception {
         writeSnapshot(
diff --git 
a/flink-connectors/flink-connector-kinesis/src/test/resources/kinesis-consumer-migration-test-flink1.16-empty-snapshot
 
b/flink-connectors/flink-connector-kinesis/src/test/resources/kinesis-consumer-migration-test-flink1.16-empty-snapshot
new file mode 100644
index 00000000000..0cdae1729a4
Binary files /dev/null and 
b/flink-connectors/flink-connector-kinesis/src/test/resources/kinesis-consumer-migration-test-flink1.16-empty-snapshot
 differ
diff --git 
a/flink-connectors/flink-connector-kinesis/src/test/resources/kinesis-consumer-migration-test-flink1.16-snapshot
 
b/flink-connectors/flink-connector-kinesis/src/test/resources/kinesis-consumer-migration-test-flink1.16-snapshot
new file mode 100644
index 00000000000..1e8d5495e55
Binary files /dev/null and 
b/flink-connectors/flink-connector-kinesis/src/test/resources/kinesis-consumer-migration-test-flink1.16-snapshot
 differ