You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by hx...@apache.org on 2022/10/31 08:00:30 UTC
[flink] 04/14: [release] Upgrade current version to 1.16 for FlinkKinesisConsumerMigrationTest and create snapshots
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 <hx...@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