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 2c9c9ad9bd935b4d777deb7d7dd9ef227fc19a17
Author: huangxingbo <h...@apache.org>
AuthorDate: Thu Oct 27 16:38:28 2022 +0800
[release] Upgrade current version to 1.16 for
FlinkKafkaProducerMigrationTest and create snapshots
---
.../kafka/FlinkKafkaProducerMigrationTest.java | 2 +-
.../kafka-migration-kafka-producer-flink-1.16-snapshot | Bin 0 -> 1242 bytes
2 files changed, 1 insertion(+), 1 deletion(-)
diff --git
a/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerMigrationTest.java
b/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerMigrationTest.java
index 754d28dff48..98ab8829634 100644
---
a/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerMigrationTest.java
+++
b/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerMigrationTest.java
@@ -42,7 +42,7 @@ import java.util.Properties;
public class FlinkKafkaProducerMigrationTest extends KafkaMigrationTestBase {
@Parameterized.Parameters(name = "Migration Savepoint: {0}")
public static Collection<FlinkVersion> parameters() {
- return FlinkVersion.rangeOf(FlinkVersion.v1_8, FlinkVersion.v1_15);
+ return FlinkVersion.rangeOf(FlinkVersion.v1_8, FlinkVersion.v1_16);
}
public FlinkKafkaProducerMigrationTest(FlinkVersion testMigrateVersion) {
diff --git
a/flink-connectors/flink-connector-kafka/src/test/resources/kafka-migration-kafka-producer-flink-1.16-snapshot
b/flink-connectors/flink-connector-kafka/src/test/resources/kafka-migration-kafka-producer-flink-1.16-snapshot
new file mode 100644
index 00000000000..de58ce37ac2
Binary files /dev/null and
b/flink-connectors/flink-connector-kafka/src/test/resources/kafka-migration-kafka-producer-flink-1.16-snapshot
differ
