commit a197dcb14998a49a833a430c971718c30dd20f62
author Piotr Nowojski <piotr.nowojski@gmail.com> Mon Oct 31 11:21:10 2022 +0100
committer MartijnVisser <martijn@2symbols.com> Mon Mar 06 20:56:30 2023 +0100
tree 4dbb5a1b3b83ff5437f07878e4c2f0fe4153e15a
parent 04e6c434fd1f13a3857e060d784074996ebb28ef

[FLINK-29807][tests] Drop support for < 1.8 snapshots in FlinkKafkaConsumerBaseMigrationTest

flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBaseMigrationTest.java

diff --git a/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBaseMigrationTest.java b/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBaseMigrationTest.java
index 909a6cc..296545c 100644
--- a/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBaseMigrationTest.java
+++ b/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBaseMigrationTest.java
@@ -92,7 +92,7 @@
 
     @Parameterized.Parameters(name = "Migration Savepoint: {0}")
     public static Collection<FlinkVersion> parameters() {
-        return FlinkVersion.rangeOf(FlinkVersion.v1_4, FlinkVersion.v1_16);
+        return FlinkVersion.rangeOf(FlinkVersion.v1_8, FlinkVersion.v1_16);
     }
 
     public FlinkKafkaConsumerBaseMigrationTest(FlinkVersion testMigrateVersion) {

flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.4-empty-state-snapshot

diff --git a/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.4-empty-state-snapshot b/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.4-empty-state-snapshot
deleted file mode 100644
index 2a06fb7..0000000
--- a/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.4-empty-state-snapshot
+++ /dev/null
Binary files differ

flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.4-snapshot

diff --git a/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.4-snapshot b/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.4-snapshot
deleted file mode 100644
index d778ca0..0000000
--- a/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.4-snapshot
+++ /dev/null
Binary files differ

flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.5-empty-state-snapshot

diff --git a/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.5-empty-state-snapshot b/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.5-empty-state-snapshot
deleted file mode 100644
index affc8b9..0000000
--- a/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.5-empty-state-snapshot
+++ /dev/null
Binary files differ

flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.5-snapshot

diff --git a/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.5-snapshot b/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.5-snapshot
deleted file mode 100644
index 773b363..0000000
--- a/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.5-snapshot
+++ /dev/null
Binary files differ

flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.6-empty-state-snapshot

diff --git a/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.6-empty-state-snapshot b/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.6-empty-state-snapshot
deleted file mode 100644
index 1b039fe..0000000
--- a/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.6-empty-state-snapshot
+++ /dev/null
Binary files differ

flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.6-snapshot

diff --git a/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.6-snapshot b/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.6-snapshot
deleted file mode 100644
index ea2e09c..0000000
--- a/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.6-snapshot
+++ /dev/null
Binary files differ

flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.7-empty-state-snapshot

diff --git a/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.7-empty-state-snapshot b/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.7-empty-state-snapshot
deleted file mode 100644
index 3b39852..0000000
--- a/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.7-empty-state-snapshot
+++ /dev/null
Binary files differ

flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.7-snapshot

diff --git a/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.7-snapshot b/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.7-snapshot
deleted file mode 100644
index da23cec..0000000
--- a/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.7-snapshot
+++ /dev/null
Binary files differ