This is an automated email from the ASF dual-hosted git repository.
twalthr pushed a commit to branch release-1.7
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.7 by this push:
new 1891949 [FLINK-10872] [e2e] Extend SQL Client end-to-end to for Kafka
0.11 connector
1891949 is described below
commit 1891949d2584e67a5edb878eac62268c447fdc1f
Author: yanghua <yanghua1...@gmail.com>
AuthorDate: Thu Nov 15 22:15:51 2018 +0800
[FLINK-10872] [e2e] Extend SQL Client end-to-end to for Kafka 0.11 connector
This closes #7100.
---
.../flink-sql-client-test/pom.xml | 7 +++----
flink-end-to-end-tests/run-nightly-tests.sh | 1 +
.../test-scripts/test_sql_client_kafka011.sh | 22 ++++++++++++++++++++++
3 files changed, 26 insertions(+), 4 deletions(-)
diff --git a/flink-end-to-end-tests/flink-sql-client-test/pom.xml
b/flink-end-to-end-tests/flink-sql-client-test/pom.xml
index 7710d01..d744065 100644
--- a/flink-end-to-end-tests/flink-sql-client-test/pom.xml
+++ b/flink-end-to-end-tests/flink-sql-client-test/pom.xml
@@ -186,19 +186,18 @@ under the License.
</artifactItem>
<artifactItem>
<groupId>org.apache.flink</groupId>
-
<artifactId>flink-connector-kafka_${scala.binary.version}</artifactId>
+
<artifactId>flink-connector-kafka-0.11_${scala.binary.version}</artifactId>
<version>${project.version}</version>
<classifier>sql-jar</classifier>
<type>jar</type>
</artifactItem>
- <!-- This SQL
JAR is not used for now to avoid dependency conflicts; see FLINK-10107.
<artifactItem>
<groupId>org.apache.flink</groupId>
-
<artifactId>flink-connector-kafka-0.11_${scala.binary.version}</artifactId>
+
<artifactId>flink-connector-kafka_${scala.binary.version}</artifactId>
<version>${project.version}</version>
<classifier>sql-jar</classifier>
<type>jar</type>
-
</artifactItem>-->
+ </artifactItem>
<artifactItem>
<groupId>org.apache.flink</groupId>
<artifactId>flink-connector-elasticsearch6_${scala.binary.version}</artifactId>
diff --git a/flink-end-to-end-tests/run-nightly-tests.sh
b/flink-end-to-end-tests/run-nightly-tests.sh
index 2187005..24d77c3 100755
--- a/flink-end-to-end-tests/run-nightly-tests.sh
+++ b/flink-end-to-end-tests/run-nightly-tests.sh
@@ -143,6 +143,7 @@ run_test "State TTL RocksDb backend end-to-end test"
"$END_TO_END_DIR/test-scrip
run_test "SQL Client end-to-end test"
"$END_TO_END_DIR/test-scripts/test_sql_client.sh"
run_test "SQL Client end-to-end test for Kafka 0.10"
"$END_TO_END_DIR/test-scripts/test_sql_client_kafka010.sh"
+run_test "SQL Client end-to-end test for Kafka 0.11"
"$END_TO_END_DIR/test-scripts/test_sql_client_kafka011.sh"
run_test "SQL Client end-to-end test for modern Kafka"
"$END_TO_END_DIR/test-scripts/test_sql_client_kafka.sh"
run_test "Heavy deployment end-to-end test"
"$END_TO_END_DIR/test-scripts/test_heavy_deployment.sh" "skip_check_exceptions"
diff --git a/flink-end-to-end-tests/test-scripts/test_sql_client_kafka011.sh
b/flink-end-to-end-tests/test-scripts/test_sql_client_kafka011.sh
new file mode 100755
index 0000000..e8ab9d0
--- /dev/null
+++ b/flink-end-to-end-tests/test-scripts/test_sql_client_kafka011.sh
@@ -0,0 +1,22 @@
+#!/usr/bin/env bash
+################################################################################
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license agreements. See the NOTICE file
+# distributed with this work for additional information
+# regarding copyright ownership. The ASF licenses this file
+# to you under the Apache License, Version 2.0 (the
+# "License"); you may not use this file except in compliance
+# with the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+################################################################################
+
+set -Eeuo pipefail
+
+source "$(dirname "$0")"/test_sql_client_kafka_common.sh 0.11 0.11.0.2 3.2.0
3.2 "kafka-0.11" "0.11"
