This is an automated email from the ASF dual-hosted git repository.
martijnvisser pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/flink-connector-kafka.git
commit a197dcb14998a49a833a430c971718c30dd20f62
Author: Piotr Nowojski <piotr.nowoj...@gmail.com>
AuthorDate: Mon Oct 31 11:21:10 2022 +0100
[FLINK-29807][tests] Drop support for < 1.8 snapshots in
FlinkKafkaConsumerBaseMigrationTest
---
.../kafka/FlinkKafkaConsumerBaseMigrationTest.java | 2 +-
...consumer-migration-test-flink1.4-empty-state-snapshot | Bin 6471 -> 0 bytes
.../kafka-consumer-migration-test-flink1.4-snapshot | Bin 6525 -> 0 bytes
...consumer-migration-test-flink1.5-empty-state-snapshot | Bin 6469 -> 0 bytes
.../kafka-consumer-migration-test-flink1.5-snapshot | Bin 6523 -> 0 bytes
...consumer-migration-test-flink1.6-empty-state-snapshot | Bin 6620 -> 0 bytes
.../kafka-consumer-migration-test-flink1.6-snapshot | Bin 6674 -> 0 bytes
...consumer-migration-test-flink1.7-empty-state-snapshot | Bin 8487 -> 0 bytes
.../kafka-consumer-migration-test-flink1.7-snapshot | Bin 8541 -> 0 bytes
9 files changed, 1 insertion(+), 1 deletion(-)
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 @@ public class FlinkKafkaConsumerBaseMigrationTest {
@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) {
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
Binary files
a/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.4-empty-state-snapshot
and /dev/null differ
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
Binary files
a/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.4-snapshot
and /dev/null differ
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
Binary files
a/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.5-empty-state-snapshot
and /dev/null differ
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
Binary files
a/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.5-snapshot
and /dev/null differ
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
Binary files
a/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.6-empty-state-snapshot
and /dev/null differ
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
Binary files
a/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.6-snapshot
and /dev/null differ
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
Binary files
a/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.7-empty-state-snapshot
and /dev/null differ
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
Binary files
a/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.7-snapshot
and /dev/null differ
