This is an automated email from the ASF dual-hosted git repository. mapohl pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit 4f8bb1843f2c425ab015eb1278594ee75725b418 Author: Matthias Pohl <[email protected]> AuthorDate: Thu Mar 23 19:12:23 2023 +0100 [FLINK-31593][tests] Adds 1.17.0 reference data for FlinkKafkaConsumerBaseMigrationTest based on release-1.17.0 --- .../kafka/FlinkKafkaConsumerBaseMigrationTest.java | 2 +- ...onsumer-migration-test-flink1.17-empty-state-snapshot | Bin 0 -> 1465 bytes .../kafka-consumer-migration-test-flink1.17-snapshot | Bin 0 -> 1519 bytes 3 files changed, 1 insertion(+), 1 deletion(-) diff --git a/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBaseMigrationTest.java b/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBaseMigrationTest.java index 296545cad04..d1c641aa63f 100644 --- a/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBaseMigrationTest.java +++ b/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBaseMigrationTest.java @@ -92,7 +92,7 @@ public class FlinkKafkaConsumerBaseMigrationTest { @Parameterized.Parameters(name = "Migration Savepoint: {0}") public static Collection<FlinkVersion> parameters() { - return FlinkVersion.rangeOf(FlinkVersion.v1_8, FlinkVersion.v1_16); + return FlinkVersion.rangeOf(FlinkVersion.v1_8, FlinkVersion.v1_17); } public FlinkKafkaConsumerBaseMigrationTest(FlinkVersion testMigrateVersion) { diff --git a/flink-connectors/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.17-empty-state-snapshot b/flink-connectors/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.17-empty-state-snapshot new file mode 100644 index 00000000000..128dcc8ff7d Binary files /dev/null and b/flink-connectors/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.17-empty-state-snapshot differ diff --git a/flink-connectors/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.17-snapshot b/flink-connectors/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.17-snapshot new file mode 100644 index 00000000000..44e8e1163a5 Binary files /dev/null and b/flink-connectors/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.17-snapshot differ
