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
commit b6237688b27ee2ca2cdda49820c5d2d541e12bbc Author: zentol <[email protected]> AuthorDate: Tue Dec 18 13:40:03 2018 +0100 [FLINK-11026][kafka][SQL] Rework kafka sql-client jar creation --- docs/dev/table/connect.md | 8 +- .../flink-connector-kafka-0.10/pom.xml | 53 ------------- .../flink-connector-kafka-0.11/pom.xml | 54 ------------- flink-connectors/flink-connector-kafka-0.9/pom.xml | 50 ------------ flink-connectors/flink-connector-kafka/pom.xml | 52 ------------- .../flink-sql-connector-kafka-0.10/pom.xml | 87 +++++++++++++++++++++ .../flink-sql-connector-kafka-0.11/pom.xml | 88 ++++++++++++++++++++++ .../flink-sql-connector-kafka-0.9/pom.xml | 86 +++++++++++++++++++++ flink-connectors/flink-sql-connector-kafka/pom.xml | 87 +++++++++++++++++++++ flink-connectors/pom.xml | 4 + .../flink-sql-client-test/pom.xml | 21 ++---- 11 files changed, 363 insertions(+), 227 deletions(-) diff --git a/docs/dev/table/connect.md b/docs/dev/table/connect.md index c05102c..27c6920 100644 --- a/docs/dev/table/connect.md +++ b/docs/dev/table/connect.md @@ -45,10 +45,10 @@ The following tables list all available connectors and formats. Their mutual com | Filesystem | | Built-in | Built-in | | Elasticsearch | 6 | `flink-connector-elasticsearch6` | [Download](http://central.maven.org/maven2/org/apache/flink/flink-sql-connector-elasticsearch6{{site.scala_version_suffix}}/{{site.version}}/flink-sql-connector-elasticsearch6{{site.scala_version_suffix}}-{{site.version}}.jar) | | Apache Kafka | 0.8 | `flink-connector-kafka-0.8` | Not available | -| Apache Kafka | 0.9 | `flink-connector-kafka-0.9` | [Download](http://central.maven.org/maven2/org/apache/flink/flink-connector-kafka-0.9{{site.scala_version_suffix}}/{{site.version}}/flink-connector-kafka-0.9{{site.scala_version_suffix}}-{{site.version}}-sql-jar.jar) | -| Apache Kafka | 0.10 | `flink-connector-kafka-0.10` | [Download](http://central.maven.org/maven2/org/apache/flink/flink-connector-kafka-0.10{{site.scala_version_suffix}}/{{site.version}}/flink-connector-kafka-0.10{{site.scala_version_suffix}}-{{site.version}}-sql-jar.jar) | -| Apache Kafka | 0.11 | `flink-connector-kafka-0.11` | [Download](http://central.maven.org/maven2/org/apache/flink/flink-connector-kafka-0.11{{site.scala_version_suffix}}/{{site.version}}/flink-connector-kafka-0.11{{site.scala_version_suffix}}-{{site.version}}-sql-jar.jar) | -| Apache Kafka | 0.11+ (`universal`) | `flink-connector-kafka` | [Download](http://central.maven.org/maven2/org/apache/flink/flink-connector-kafka{{site.scala_version_suffix}}/{{site.version}}/flink-connector-kafka{{site.scala_version_suffix}}-{{site.version}}-sql-jar.jar) | +| Apache Kafka | 0.9 | `flink-connector-kafka-0.9` | [Download](http://central.maven.org/maven2/org/apache/flink/flink-sql-connector-kafka-0.9{{site.scala_version_suffix}}/{{site.version}}/flink-sql-connector-kafka-0.9{{site.scala_version_suffix}}-{{site.version}}.jar) | +| Apache Kafka | 0.10 | `flink-connector-kafka-0.10` | [Download](http://central.maven.org/maven2/org/apache/flink/flink-sql-connector-kafka-0.10{{site.scala_version_suffix}}/{{site.version}}/flink-sql-connector-kafka-0.10{{site.scala_version_suffix}}-{{site.version}}.jar) | +| Apache Kafka | 0.11 | `flink-connector-kafka-0.11` | [Download](http://central.maven.org/maven2/org/apache/flink/flink-sql-connector-kafka-0.11{{site.scala_version_suffix}}/{{site.version}}/flink-sql-connector-kafka-0.11{{site.scala_version_suffix}}-{{site.version}}.jar) | +| Apache Kafka | 0.11+ (`universal`) | `flink-connector-kafka` | [Download](http://central.maven.org/maven2/org/apache/flink/flink-sql-connector-kafka{{site.scala_version_suffix}}/{{site.version}}/flink-sql-connector-kafka{{site.scala_version_suffix}}-{{site.version}}.jar) | ### Formats diff --git a/flink-connectors/flink-connector-kafka-0.10/pom.xml b/flink-connectors/flink-connector-kafka-0.10/pom.xml index 75ced03..8871d79 100644 --- a/flink-connectors/flink-connector-kafka-0.10/pom.xml +++ b/flink-connectors/flink-connector-kafka-0.10/pom.xml @@ -174,59 +174,6 @@ under the License. </dependencies> - <profiles> - <!-- Create SQL Client uber jars by default --> - <profile> - <id>sql-jars</id> - <activation> - <property> - <name>!skipSqlJars</name> - </property> - </activation> - <build> - <plugins> - <plugin> - <groupId>org.apache.maven.plugins</groupId> - <artifactId>maven-shade-plugin</artifactId> - <executions> - <execution> - <phase>package</phase> - <goals> - <goal>shade</goal> - </goals> - <configuration> - <shadedArtifactAttached>true</shadedArtifactAttached> - <shadedClassifierName>sql-jar</shadedClassifierName> - <artifactSet> - <includes combine.children="append"> - <include>org.apache.kafka:*</include> - <include>org.apache.flink:flink-connector-kafka-base_${scala.binary.version}</include> - <include>org.apache.flink:flink-connector-kafka-0.9_${scala.binary.version}</include> - </includes> - </artifactSet> - <filters> - <filter> - <artifact>*:*</artifact> - <excludes> - <exclude>kafka/kafka-version.properties</exclude> - </excludes> - </filter> - </filters> - <relocations> - <relocation> - <pattern>org.apache.kafka</pattern> - <shadedPattern>org.apache.flink.kafka010.shaded.org.apache.kafka</shadedPattern> - </relocation> - </relocations> - </configuration> - </execution> - </executions> - </plugin> - </plugins> - </build> - </profile> - </profiles> - <build> <plugins> <plugin> diff --git a/flink-connectors/flink-connector-kafka-0.11/pom.xml b/flink-connectors/flink-connector-kafka-0.11/pom.xml index cf25ee9..d44ab8d 100644 --- a/flink-connectors/flink-connector-kafka-0.11/pom.xml +++ b/flink-connectors/flink-connector-kafka-0.11/pom.xml @@ -182,60 +182,6 @@ under the License. </dependencies> - <profiles> - <!-- Create SQL Client uber jars by default --> - <profile> - <id>sql-jars</id> - <activation> - <property> - <name>!skipSqlJars</name> - </property> - </activation> - <build> - <plugins> - <plugin> - <groupId>org.apache.maven.plugins</groupId> - <artifactId>maven-shade-plugin</artifactId> - <executions> - <execution> - <phase>package</phase> - <goals> - <goal>shade</goal> - </goals> - <configuration> - <shadedArtifactAttached>true</shadedArtifactAttached> - <shadedClassifierName>sql-jar</shadedClassifierName> - <artifactSet> - <includes combine.children="append"> - <include>org.apache.kafka:*</include> - <include>org.apache.flink:flink-connector-kafka-base_${scala.binary.version}</include> - <include>org.apache.flink:flink-connector-kafka-0.9_${scala.binary.version}</include> - <include>org.apache.flink:flink-connector-kafka-0.10_${scala.binary.version}</include> - </includes> - </artifactSet> - <filters> - <filter> - <artifact>*:*</artifact> - <excludes> - <exclude>kafka/kafka-version.properties</exclude> - </excludes> - </filter> - </filters> - <relocations> - <relocation> - <pattern>org.apache.kafka</pattern> - <shadedPattern>org.apache.flink.kafka011.shaded.org.apache.kafka</shadedPattern> - </relocation> - </relocations> - </configuration> - </execution> - </executions> - </plugin> - </plugins> - </build> - </profile> - </profiles> - <build> <plugins> <plugin> diff --git a/flink-connectors/flink-connector-kafka-0.9/pom.xml b/flink-connectors/flink-connector-kafka-0.9/pom.xml index 2881291..3ac8554 100644 --- a/flink-connectors/flink-connector-kafka-0.9/pom.xml +++ b/flink-connectors/flink-connector-kafka-0.9/pom.xml @@ -174,56 +174,6 @@ under the License. </dependency> </dependencies> </profile> - - <!-- Create SQL Client uber jars by default --> - <profile> - <id>sql-jars</id> - <activation> - <property> - <name>!skipSqlJars</name> - </property> - </activation> - <build> - <plugins> - <plugin> - <groupId>org.apache.maven.plugins</groupId> - <artifactId>maven-shade-plugin</artifactId> - <executions> - <execution> - <phase>package</phase> - <goals> - <goal>shade</goal> - </goals> - <configuration> - <shadedArtifactAttached>true</shadedArtifactAttached> - <shadedClassifierName>sql-jar</shadedClassifierName> - <artifactSet> - <includes combine.children="append"> - <include>org.apache.kafka:*</include> - <include>org.apache.flink:flink-connector-kafka-base_${scala.binary.version}</include> - </includes> - </artifactSet> - <filters> - <filter> - <artifact>*:*</artifact> - <excludes> - <exclude>kafka/kafka-version.properties</exclude> - </excludes> - </filter> - </filters> - <relocations> - <relocation> - <pattern>org.apache.kafka</pattern> - <shadedPattern>org.apache.flink.kafka09.shaded.org.apache.kafka</shadedPattern> - </relocation> - </relocations> - </configuration> - </execution> - </executions> - </plugin> - </plugins> - </build> - </profile> </profiles> <build> diff --git a/flink-connectors/flink-connector-kafka/pom.xml b/flink-connectors/flink-connector-kafka/pom.xml index 53760089..30f6a5f 100644 --- a/flink-connectors/flink-connector-kafka/pom.xml +++ b/flink-connectors/flink-connector-kafka/pom.xml @@ -165,58 +165,6 @@ under the License. </dependencies> - <profiles> - <!-- Create SQL Client uber jars by default --> - <profile> - <id>sql-jars</id> - <activation> - <property> - <name>!skipSqlJars</name> - </property> - </activation> - <build> - <plugins> - <plugin> - <groupId>org.apache.maven.plugins</groupId> - <artifactId>maven-shade-plugin</artifactId> - <executions> - <execution> - <phase>package</phase> - <goals> - <goal>shade</goal> - </goals> - <configuration> - <shadedArtifactAttached>true</shadedArtifactAttached> - <shadedClassifierName>sql-jar</shadedClassifierName> - <artifactSet> - <includes combine.children="append"> - <include>org.apache.kafka:*</include> - <include>org.apache.flink:flink-connector-kafka-base_${scala.binary.version}</include> - </includes> - </artifactSet> - <filters> - <filter> - <artifact>*:*</artifact> - <excludes> - <exclude>kafka/kafka-version.properties</exclude> - </excludes> - </filter> - </filters> - <relocations> - <relocation> - <pattern>org.apache.kafka</pattern> - <shadedPattern>org.apache.flink.kafka.shaded.org.apache.kafka</shadedPattern> - </relocation> - </relocations> - </configuration> - </execution> - </executions> - </plugin> - </plugins> - </build> - </profile> - </profiles> - <build> <plugins> <plugin> diff --git a/flink-connectors/flink-sql-connector-kafka-0.10/pom.xml b/flink-connectors/flink-sql-connector-kafka-0.10/pom.xml new file mode 100644 index 0000000..0602757 --- /dev/null +++ b/flink-connectors/flink-sql-connector-kafka-0.10/pom.xml @@ -0,0 +1,87 @@ +<?xml version="1.0" encoding="UTF-8"?> +<!-- +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. +--> +<project xmlns="http://maven.apache.org/POM/4.0.0"; + xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; + xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd";> + + <modelVersion>4.0.0</modelVersion> + + <parent> + <groupId>org.apache.flink</groupId> + <artifactId>flink-connectors</artifactId> + <version>1.8-SNAPSHOT</version> + <relativePath>..</relativePath> + </parent> + + <artifactId>flink-sql-connector-kafka-0.10_${scala.binary.version}</artifactId> + <name>flink-sql-connector-kafka-0.10</name> + + <packaging>jar</packaging> + + <dependencies> + <dependency> + <groupId>org.apache.flink</groupId> + <artifactId>flink-connector-kafka-0.10_${scala.binary.version}</artifactId> + <version>${project.version}</version> + </dependency> + </dependencies> + + <build> + <plugins> + <plugin> + <groupId>org.apache.maven.plugins</groupId> + <artifactId>maven-shade-plugin</artifactId> + <executions> + <execution> + <id>shade-flink</id> + <phase>package</phase> + <goals> + <goal>shade</goal> + </goals> + <configuration> + <artifactSet> + <includes> + <include>org.apache.kafka:*</include> + <include>org.apache.flink:flink-connector-kafka-base_${scala.binary.version}</include> + <include>org.apache.flink:flink-connector-kafka-0.9_${scala.binary.version}</include> + <include>org.apache.flink:flink-connector-kafka-0.10_${scala.binary.version}</include> + </includes> + </artifactSet> + <filters> + <filter> + <artifact>*:*</artifact> + <excludes> + <exclude>kafka/kafka-version.properties</exclude> + </excludes> + </filter> + </filters> + <relocations> + <relocation> + <pattern>org.apache.kafka</pattern> + <shadedPattern>org.apache.flink.kafka010.shaded.org.apache.kafka</shadedPattern> + </relocation> + </relocations> + </configuration> + </execution> + </executions> + </plugin> + </plugins> + </build> +</project> diff --git a/flink-connectors/flink-sql-connector-kafka-0.11/pom.xml b/flink-connectors/flink-sql-connector-kafka-0.11/pom.xml new file mode 100644 index 0000000..4b031a1 --- /dev/null +++ b/flink-connectors/flink-sql-connector-kafka-0.11/pom.xml @@ -0,0 +1,88 @@ +<?xml version="1.0" encoding="UTF-8"?> +<!-- +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. +--> +<project xmlns="http://maven.apache.org/POM/4.0.0"; + xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; + xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd";> + + <modelVersion>4.0.0</modelVersion> + + <parent> + <groupId>org.apache.flink</groupId> + <artifactId>flink-connectors</artifactId> + <version>1.8-SNAPSHOT</version> + <relativePath>..</relativePath> + </parent> + + <artifactId>flink-sql-connector-kafka-0.11_${scala.binary.version}</artifactId> + <name>flink-sql-connector-kafka-0.11</name> + + <packaging>jar</packaging> + + <dependencies> + <dependency> + <groupId>org.apache.flink</groupId> + <artifactId>flink-connector-kafka-0.11_${scala.binary.version}</artifactId> + <version>${project.version}</version> + </dependency> + </dependencies> + + <build> + <plugins> + <plugin> + <groupId>org.apache.maven.plugins</groupId> + <artifactId>maven-shade-plugin</artifactId> + <executions> + <execution> + <id>shade-flink</id> + <phase>package</phase> + <goals> + <goal>shade</goal> + </goals> + <configuration> + <artifactSet> + <includes> + <include>org.apache.kafka:*</include> + <include>org.apache.flink:flink-connector-kafka-base_${scala.binary.version}</include> + <include>org.apache.flink:flink-connector-kafka-0.9_${scala.binary.version}</include> + <include>org.apache.flink:flink-connector-kafka-0.10_${scala.binary.version}</include> + <include>org.apache.flink:flink-connector-kafka-0.11_${scala.binary.version}</include> + </includes> + </artifactSet> + <filters> + <filter> + <artifact>*:*</artifact> + <excludes> + <exclude>kafka/kafka-version.properties</exclude> + </excludes> + </filter> + </filters> + <relocations> + <relocation> + <pattern>org.apache.kafka</pattern> + <shadedPattern>org.apache.flink.kafka011.shaded.org.apache.kafka</shadedPattern> + </relocation> + </relocations> + </configuration> + </execution> + </executions> + </plugin> + </plugins> + </build> +</project> diff --git a/flink-connectors/flink-sql-connector-kafka-0.9/pom.xml b/flink-connectors/flink-sql-connector-kafka-0.9/pom.xml new file mode 100644 index 0000000..4668ee5 --- /dev/null +++ b/flink-connectors/flink-sql-connector-kafka-0.9/pom.xml @@ -0,0 +1,86 @@ +<?xml version="1.0" encoding="UTF-8"?> +<!-- +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. +--> +<project xmlns="http://maven.apache.org/POM/4.0.0"; + xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; + xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd";> + + <modelVersion>4.0.0</modelVersion> + + <parent> + <groupId>org.apache.flink</groupId> + <artifactId>flink-connectors</artifactId> + <version>1.8-SNAPSHOT</version> + <relativePath>..</relativePath> + </parent> + + <artifactId>flink-sql-connector-kafka-0.9_${scala.binary.version}</artifactId> + <name>flink-sql-connector-kafka-0.9</name> + + <packaging>jar</packaging> + + <dependencies> + <dependency> + <groupId>org.apache.flink</groupId> + <artifactId>flink-connector-kafka-0.9_${scala.binary.version}</artifactId> + <version>${project.version}</version> + </dependency> + </dependencies> + + <build> + <plugins> + <plugin> + <groupId>org.apache.maven.plugins</groupId> + <artifactId>maven-shade-plugin</artifactId> + <executions> + <execution> + <id>shade-flink</id> + <phase>package</phase> + <goals> + <goal>shade</goal> + </goals> + <configuration> + <artifactSet> + <includes> + <include>org.apache.kafka:*</include> + <include>org.apache.flink:flink-connector-kafka-0.9_${scala.binary.version}</include> + <include>org.apache.flink:flink-connector-kafka-base_${scala.binary.version}</include> + </includes> + </artifactSet> + <filters> + <filter> + <artifact>*:*</artifact> + <excludes> + <exclude>kafka/kafka-version.properties</exclude> + </excludes> + </filter> + </filters> + <relocations> + <relocation> + <pattern>org.apache.kafka</pattern> + <shadedPattern>org.apache.flink.kafka09.shaded.org.apache.kafka</shadedPattern> + </relocation> + </relocations> + </configuration> + </execution> + </executions> + </plugin> + </plugins> + </build> +</project> diff --git a/flink-connectors/flink-sql-connector-kafka/pom.xml b/flink-connectors/flink-sql-connector-kafka/pom.xml new file mode 100644 index 0000000..8a2609e --- /dev/null +++ b/flink-connectors/flink-sql-connector-kafka/pom.xml @@ -0,0 +1,87 @@ +<?xml version="1.0" encoding="UTF-8"?> +<!-- +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. +--> +<project xmlns="http://maven.apache.org/POM/4.0.0"; + xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; + xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd";> + + <modelVersion>4.0.0</modelVersion> + + <parent> + <artifactId>flink-connectors</artifactId> + <groupId>org.apache.flink</groupId> + <version>1.8-SNAPSHOT</version> + <relativePath>..</relativePath> + </parent> + + <artifactId>flink-sql-connector-kafka_${scala.binary.version}</artifactId> + <name>flink-sql-connector-kafka</name> + + <packaging>jar</packaging> + + <dependencies> + <dependency> + <groupId>org.apache.flink</groupId> + <artifactId>flink-connector-kafka_${scala.binary.version}</artifactId> + <version>${project.version}</version> + </dependency> + </dependencies> + + <build> + <plugins> + <plugin> + <groupId>org.apache.maven.plugins</groupId> + <artifactId>maven-shade-plugin</artifactId> + <executions> + <execution> + <id>shade-flink</id> + <phase>package</phase> + <goals> + <goal>shade</goal> + </goals> + <configuration> + <shadeTestJar>false</shadeTestJar> + <artifactSet> + <includes> + <include>org.apache.kafka:*</include> + <include>org.apache.flink:flink-connector-kafka_${scala.binary.version}</include> + <include>org.apache.flink:flink-connector-kafka-base_${scala.binary.version}</include> + </includes> + </artifactSet> + <filters> + <filter> + <artifact>*:*</artifact> + <excludes> + <exclude>kafka/kafka-version.properties</exclude> + </excludes> + </filter> + </filters> + <relocations> + <relocation> + <pattern>org.apache.kafka</pattern> + <shadedPattern>org.apache.flink.kafka.shaded.org.apache.kafka</shadedPattern> + </relocation> + </relocations> + </configuration> + </execution> + </executions> + </plugin> + </plugins> + </build> +</project> diff --git a/flink-connectors/pom.xml b/flink-connectors/pom.xml index 807f03d..80b0c25 100644 --- a/flink-connectors/pom.xml +++ b/flink-connectors/pom.xml @@ -93,6 +93,10 @@ under the License. </activation> <modules> <module>flink-sql-connector-elasticsearch6</module> + <module>flink-sql-connector-kafka-0.9</module> + <module>flink-sql-connector-kafka-0.10</module> + <module>flink-sql-connector-kafka-0.11</module> + <module>flink-sql-connector-kafka</module> </modules> </profile> 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 3b04f8f..ad54b3a 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 @@ -63,33 +63,29 @@ under the License. <dependency> <!-- Used by maven-dependency-plugin --> <groupId>org.apache.flink</groupId> - <artifactId>flink-connector-kafka-0.9_${scala.binary.version}</artifactId> + <artifactId>flink-sql-connector-kafka-0.9_${scala.binary.version}</artifactId> <version>${project.version}</version> - <classifier>sql-jar</classifier> <scope>provided</scope> </dependency> <dependency> <!-- Used by maven-dependency-plugin --> <groupId>org.apache.flink</groupId> - <artifactId>flink-connector-kafka-0.10_${scala.binary.version}</artifactId> + <artifactId>flink-sql-connector-kafka-0.10_${scala.binary.version}</artifactId> <version>${project.version}</version> - <classifier>sql-jar</classifier> <scope>provided</scope> </dependency> <dependency> <!-- Used by maven-dependency-plugin --> <groupId>org.apache.flink</groupId> - <artifactId>flink-connector-kafka-0.11_${scala.binary.version}</artifactId> + <artifactId>flink-sql-connector-kafka-0.11_${scala.binary.version}</artifactId> <version>${project.version}</version> - <classifier>sql-jar</classifier> <scope>provided</scope> </dependency> <dependency> <!-- Used by maven-dependency-plugin --> <groupId>org.apache.flink</groupId> - <artifactId>flink-connector-kafka_${scala.binary.version}</artifactId> + <artifactId>flink-sql-connector-kafka_${scala.binary.version}</artifactId> <version>${project.version}</version> - <classifier>sql-jar</classifier> <scope>provided</scope> </dependency> <dependency> @@ -173,23 +169,20 @@ under the License. </artifactItem>--> <artifactItem> <groupId>org.apache.flink</groupId> - <artifactId>flink-connector-kafka-0.10_${scala.binary.version}</artifactId> + <artifactId>flink-sql-connector-kafka-0.10_${scala.binary.version}</artifactId> <version>${project.version}</version> - <classifier>sql-jar</classifier> <type>jar</type> </artifactItem> <artifactItem> <groupId>org.apache.flink</groupId> - <artifactId>flink-connector-kafka-0.11_${scala.binary.version}</artifactId> + <artifactId>flink-sql-connector-kafka-0.11_${scala.binary.version}</artifactId> <version>${project.version}</version> - <classifier>sql-jar</classifier> <type>jar</type> </artifactItem> <artifactItem> <groupId>org.apache.flink</groupId> - <artifactId>flink-connector-kafka_${scala.binary.version}</artifactId> + <artifactId>flink-sql-connector-kafka_${scala.binary.version}</artifactId> <version>${project.version}</version> - <classifier>sql-jar</classifier> <type>jar</type> </artifactItem> <artifactItem>
