This is an automated email from the ASF dual-hosted git repository.

pnowojski pushed a commit to branch release-1.11
in repository https://gitbox.apache.org/repos/asf/flink.git

commit 7cfd72d489e27049e1f82501c461f855b690f0c2
Author: Yun Gao <[email protected]>
AuthorDate: Thu Jul 23 23:14:57 2020 +0800

    [FLINK-18552][tests] Update migration tests of 
FlinkKinesisConsumerMigrationTest to cover migration from 1.11
---
 .../kinesis/FlinkKinesisConsumerMigrationTest.java       |   3 ++-
 ...esis-consumer-migration-test-flink1.11-empty-snapshot | Bin 0 -> 2870 bytes
 .../kinesis-consumer-migration-test-flink1.11-snapshot   | Bin 0 -> 2938 bytes
 3 files changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumerMigrationTest.java
 
b/flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumerMigrationTest.java
index 6aa5956..0213587 100644
--- 
a/flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumerMigrationTest.java
+++ 
b/flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumerMigrationTest.java
@@ -102,7 +102,8 @@ public class FlinkKinesisConsumerMigrationTest {
                        MigrationVersion.v1_7,
                        MigrationVersion.v1_8,
                        MigrationVersion.v1_9,
-                       MigrationVersion.v1_10);
+                       MigrationVersion.v1_10,
+                       MigrationVersion.v1_11);
        }
 
        public FlinkKinesisConsumerMigrationTest(MigrationVersion 
testMigrateVersion) {
diff --git 
a/flink-connectors/flink-connector-kinesis/src/test/resources/kinesis-consumer-migration-test-flink1.11-empty-snapshot
 
b/flink-connectors/flink-connector-kinesis/src/test/resources/kinesis-consumer-migration-test-flink1.11-empty-snapshot
new file mode 100644
index 0000000..8c83f09
Binary files /dev/null and 
b/flink-connectors/flink-connector-kinesis/src/test/resources/kinesis-consumer-migration-test-flink1.11-empty-snapshot
 differ
diff --git 
a/flink-connectors/flink-connector-kinesis/src/test/resources/kinesis-consumer-migration-test-flink1.11-snapshot
 
b/flink-connectors/flink-connector-kinesis/src/test/resources/kinesis-consumer-migration-test-flink1.11-snapshot
new file mode 100644
index 0000000..a4bf97c
Binary files /dev/null and 
b/flink-connectors/flink-connector-kinesis/src/test/resources/kinesis-consumer-migration-test-flink1.11-snapshot
 differ

Reply via email to