zentol closed pull request #7341: [FLINK-11026][kafka][SQL] Rework kafka sql-client jar creation URL: https://github.com/apache/flink/pull/7341
This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of provenance: As this is a foreign pull request (from a fork), the diff is supplied below (as it won't show otherwise due to GitHub magic): diff --git a/docs/dev/table/connect.md b/docs/dev/table/connect.md index 2255f1f0dfc..0d67444c184 100644 --- a/docs/dev/table/connect.md +++ b/docs/dev/table/connect.md @@ -45,10 +45,10 @@ The following table list all available connectors and formats. Their mutual comp | 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 75ced033e90..8871d791e4f 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 cf25ee933bb..d44ab8d8ff7 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 28812919550..3ac8554a7a8 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 53760089cb1..30f6a5fe28e 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-elasticsearch6/pom.xml b/flink-connectors/flink-sql-connector-elasticsearch6/pom.xml index 85b73a9c837..57c143a28d4 100644 --- a/flink-connectors/flink-sql-connector-elasticsearch6/pom.xml +++ b/flink-connectors/flink-sql-connector-elasticsearch6/pom.xml @@ -35,11 +35,6 @@ under the License. <packaging>jar</packaging> - <!-- Allow users to pass custom connector versions --> - <properties> - <elasticsearch.version>6.3.1</elasticsearch.version> - </properties> - <dependencies> <dependency> <groupId>org.apache.flink</groupId> 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 00000000000..06027573b32 --- /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 00000000000..4b031a13a72 --- /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 00000000000..4668ee5f64b --- /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 00000000000..8a2609ed6a7 --- /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 807f03d5343..80b0c257c61 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 3b04f8f61c9..ad54b3a6625 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> ---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
