You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2018/12/18 14:19:49 UTC
[flink] branch master updated: [FLINK-10784][tests] Update
FlinkKafkaConsumerBaseMigrationTest for 1.7
This is an automated email from the ASF dual-hosted git repository.
chesnay 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 4616c60 [FLINK-10784][tests] Update FlinkKafkaConsumerBaseMigrationTest for 1.7
4616c60 is described below
commit 4616c605965860228959f7bcf481771477734f56
Author: vinoyang <ya...@gmail.com>
AuthorDate: Tue Dec 18 22:19:42 2018 +0800
[FLINK-10784][tests] Update FlinkKafkaConsumerBaseMigrationTest for 1.7
---
.../kafka/FlinkKafkaConsumerBaseMigrationTest.java | 3 ++-
...consumer-migration-test-flink1.7-empty-state-snapshot | Bin 0 -> 8487 bytes
.../kafka-consumer-migration-test-flink1.7-snapshot | Bin 0 -> 8541 bytes
3 files changed, 2 insertions(+), 1 deletion(-)
diff --git a/flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBaseMigrationTest.java b/flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBaseMigrationTest.java
index 74770d0..decb5cf 100644
--- a/flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBaseMigrationTest.java
+++ b/flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBaseMigrationTest.java
@@ -98,7 +98,8 @@ public class FlinkKafkaConsumerBaseMigrationTest {
MigrationVersion.v1_3,
MigrationVersion.v1_4,
MigrationVersion.v1_5,
- MigrationVersion.v1_6);
+ MigrationVersion.v1_6,
+ MigrationVersion.v1_7);
}
public FlinkKafkaConsumerBaseMigrationTest(MigrationVersion testMigrateVersion) {
diff --git a/flink-connectors/flink-connector-kafka-base/src/test/resources/kafka-consumer-migration-test-flink1.7-empty-state-snapshot b/flink-connectors/flink-connector-kafka-base/src/test/resources/kafka-consumer-migration-test-flink1.7-empty-state-snapshot
new file mode 100644
index 0000000..3b39852
Binary files /dev/null and b/flink-connectors/flink-connector-kafka-base/src/test/resources/kafka-consumer-migration-test-flink1.7-empty-state-snapshot differ
diff --git a/flink-connectors/flink-connector-kafka-base/src/test/resources/kafka-consumer-migration-test-flink1.7-snapshot b/flink-connectors/flink-connector-kafka-base/src/test/resources/kafka-consumer-migration-test-flink1.7-snapshot
new file mode 100644
index 0000000..da23cec
Binary files /dev/null and b/flink-connectors/flink-connector-kafka-base/src/test/resources/kafka-consumer-migration-test-flink1.7-snapshot differ