[flink] branch release-1.11 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 release-1.11
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/release-1.11 by this push:
     new bad13ad  [hotfix][e2e] Sync kafka 0.10 versions
bad13ad is described below

commit bad13adecd9f7e3c3586025992ca158e62268420
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 4e8d061..98ac98b 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"}
                });