This is an automated email from the ASF dual-hosted git repository. trohrmann pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push: new 99198c7 [FLINK-13620][Tests] Update FlinkKafkaProducerMigrationTest to restore from 1.9 savepoint 99198c7 is described below commit 99198c771ddc9326156e138d9c8ba9b7ea3aa0ad Author: yanghua <yanghua1...@gmail.com> AuthorDate: Tue Sep 3 20:02:43 2019 +0800 [FLINK-13620][Tests] Update FlinkKafkaProducerMigrationTest to restore from 1.9 savepoint This closes #9599. --- .../kafka/FlinkKafkaProducerMigrationTest.java | 3 ++- .../kafka-migration-kafka-producer-flink-1.9-snapshot | Bin 0 -> 1232 bytes 2 files changed, 2 insertions(+), 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 508f0b5..10a6fee 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 @@ -44,7 +44,8 @@ public class FlinkKafkaProducerMigrationTest extends KafkaMigrationTestBase { @Parameterized.Parameters(name = "Migration Savepoint: {0}") public static Collection<MigrationVersion> parameters() { return Arrays.asList( - MigrationVersion.v1_8); + MigrationVersion.v1_8, + MigrationVersion.v1_9); } public FlinkKafkaProducerMigrationTest(MigrationVersion testMigrateVersion) { diff --git a/flink-connectors/flink-connector-kafka/src/test/resources/kafka-migration-kafka-producer-flink-1.9-snapshot b/flink-connectors/flink-connector-kafka/src/test/resources/kafka-migration-kafka-producer-flink-1.9-snapshot new file mode 100644 index 0000000..c860898 Binary files /dev/null and b/flink-connectors/flink-connector-kafka/src/test/resources/kafka-migration-kafka-producer-flink-1.9-snapshot differ