[flink] branch master updated: [hotfix][e2e] Sync kafka 0.10 versions

[chesnay]

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 efd4974  [hotfix][e2e] Sync kafka 0.10 versions
efd4974 is described below

commit efd497410ced3386b955a92b731a8e758223045f
Author: Chesnay Schepler <ches...@apache.org>
AuthorDate: Tue Jun 16 10:46:27 2020 +0200

    [hotfix][e2e] Sync kafka 0.10 versions
---
 .../java/org/apache/flink/tests/util/kafka/SQLClientKafkaITCase.java    | 2 +-
 .../java/org/apache/flink/tests/util/kafka/StreamingKafkaITCase.java    | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/SQLClientKafkaITCase.java
 
b/flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/SQLClientKafkaITCase.java
index 9a86960..cdae9ca 100644
--- 
a/flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/SQLClientKafkaITCase.java
+++ 
b/flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/SQLClientKafkaITCase.java
@@ -79,7 +79,7 @@ public class SQLClientKafkaITCase extends TestLogger {
        @Parameterized.Parameters(name = "{index}: kafka-version:{1} 
kafka-sql-version:{2}")
        public static Collection<Object[]> data() {
                return Arrays.asList(new Object[][]{
-                               {"0.10.2.0", "0.10", ".*kafka-0.10.jar"},
+                               {"0.10.2.2", "0.10", ".*kafka-0.10.jar"},
                                {"0.11.0.2", "0.11", ".*kafka-0.11.jar"},
                                {"2.4.1", "universal", ".*kafka.jar"}
                });
diff --git 
a/flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/StreamingKafkaITCase.java
 
b/flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/StreamingKafkaITCase.java
index a257858..d5c194d 100644
--- 
a/flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/StreamingKafkaITCase.java
+++ 
b/flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/StreamingKafkaITCase.java
@@ -58,7 +58,7 @@ public class StreamingKafkaITCase extends TestLogger {
        @Parameterized.Parameters(name = "{index}: kafka-version:{1}")
        public static Collection<Object[]> data() {
                return Arrays.asList(new Object[][]{
-                       {"flink-streaming-kafka010-test.*", "0.10.2.0"},
+                       {"flink-streaming-kafka010-test.*", "0.10.2.2"},
                        {"flink-streaming-kafka011-test.*", "0.11.0.2"},
                        {"flink-streaming-kafka-test.*", "2.4.1"}
                });