[FLINK-18552][tests] Update migration tests of FlinkKafkaProducerMigr…

…ationTest to cover migration from 1.10
spotify · Jul 24, 2020 · 9535ffc · 9535ffc
1 parent 47c3394
commit 9535ffc
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/...est/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerMigrationTest.java b/...est/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerMigrationTest.java
@@ -45,7 +45,8 @@ public class FlinkKafkaProducerMigrationTest extends KafkaMigrationTestBase {
  public static Collection<MigrationVersion> parameters() {
  return Arrays.asList(
  MigrationVersion.v1_8,
- MigrationVersion.v1_9);
+ MigrationVersion.v1_9,
+ MigrationVersion.v1_10);
  }
 
  public FlinkKafkaProducerMigrationTest(MigrationVersion testMigrateVersion) {

diff --git a/...ink-connector-kafka/src/test/resources/kafka-migration-kafka-producer-flink-1.10-snapshot b/...ink-connector-kafka/src/test/resources/kafka-migration-kafka-producer-flink-1.10-snapshot