Unverified Commit af7952e4 authored by wmtbnbo's avatar wmtbnbo Committed by GitHub

[Feature] [bug] Update flink version and fix Flink and CDC version compatibility bug (#687)

* [Feature] Update flink1.14 to flink1.14.5

* [Bug] [dlink-flink] Fix the local operation exception caused by the conflict between the CDC package and the Flink clients package
parent 8721f5d5
...@@ -14,7 +14,7 @@ ...@@ -14,7 +14,7 @@
<properties> <properties>
<java.version>1.8</java.version> <java.version>1.8</java.version>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<flink.version>1.14.3</flink.version> <flink.version>1.14.5</flink.version>
<maven.compiler.source>1.8</maven.compiler.source> <maven.compiler.source>1.8</maven.compiler.source>
<maven.compiler.target>1.8</maven.compiler.target> <maven.compiler.target>1.8</maven.compiler.target>
<junit.version>4.12</junit.version> <junit.version>4.12</junit.version>
......
...@@ -15,7 +15,7 @@ ...@@ -15,7 +15,7 @@
<properties> <properties>
<java.version>1.8</java.version> <java.version>1.8</java.version>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<flink.version>1.14.3</flink.version> <flink.version>1.14.5</flink.version>
<maven.compiler.source>1.8</maven.compiler.source> <maven.compiler.source>1.8</maven.compiler.source>
<maven.compiler.target>1.8</maven.compiler.target> <maven.compiler.target>1.8</maven.compiler.target>
<junit.version>4.12</junit.version> <junit.version>4.12</junit.version>
......
...@@ -14,7 +14,8 @@ ...@@ -14,7 +14,8 @@
<properties> <properties>
<java.version>1.8</java.version> <java.version>1.8</java.version>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<flink.version>1.14.4</flink.version> <flink.version>1.14.5</flink.version>
<flink.guava.version>14.0</flink.guava.version>
<flinkcdc.version>2.2.1</flinkcdc.version> <flinkcdc.version>2.2.1</flinkcdc.version>
<commons.version>1.3.1</commons.version> <commons.version>1.3.1</commons.version>
<maven.compiler.source>1.8</maven.compiler.source> <maven.compiler.source>1.8</maven.compiler.source>
...@@ -82,14 +83,19 @@ ...@@ -82,14 +83,19 @@
<artifactId>flink-connector-kafka_${scala.binary.version}</artifactId> <artifactId>flink-connector-kafka_${scala.binary.version}</artifactId>
<version>${flink.version}</version> <version>${flink.version}</version>
</dependency> </dependency>
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-shaded-guava</artifactId>
<version>30.1.1-jre-${flink.guava.version}</version>
</dependency>
<dependency> <dependency>
<groupId>com.ververica</groupId> <groupId>com.ververica</groupId>
<artifactId>flink-connector-mysql-cdc</artifactId> <artifactId>flink-sql-connector-mysql-cdc</artifactId>
<version>${flinkcdc.version}</version> <version>${flinkcdc.version}</version>
</dependency> </dependency>
<dependency> <dependency>
<groupId>com.ververica</groupId> <groupId>com.ververica</groupId>
<artifactId>flink-connector-oracle-cdc</artifactId> <artifactId>flink-sql-connector-oracle-cdc</artifactId>
<version>${flinkcdc.version}</version> <version>${flinkcdc.version}</version>
</dependency> </dependency>
<dependency> <dependency>
......
...@@ -15,6 +15,7 @@ ...@@ -15,6 +15,7 @@
<java.version>1.8</java.version> <java.version>1.8</java.version>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<flink.version>1.15.0</flink.version> <flink.version>1.15.0</flink.version>
<flink.guava.version>15.0</flink.guava.version>
<flinkcdc.version>2.2.1</flinkcdc.version> <flinkcdc.version>2.2.1</flinkcdc.version>
<commons.version>1.3.1</commons.version> <commons.version>1.3.1</commons.version>
<maven.compiler.source>1.8</maven.compiler.source> <maven.compiler.source>1.8</maven.compiler.source>
...@@ -102,14 +103,19 @@ ...@@ -102,14 +103,19 @@
<artifactId>flink-connector-kafka</artifactId> <artifactId>flink-connector-kafka</artifactId>
<version>${flink.version}</version> <version>${flink.version}</version>
</dependency> </dependency>
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-shaded-guava</artifactId>
<version>30.1.1-jre-${flink.guava.version}</version>
</dependency>
<dependency> <dependency>
<groupId>com.ververica</groupId> <groupId>com.ververica</groupId>
<artifactId>flink-connector-mysql-cdc</artifactId> <artifactId>flink-sql-connector-mysql-cdc</artifactId>
<version>${flinkcdc.version}</version> <version>${flinkcdc.version}</version>
</dependency> </dependency>
<dependency> <dependency>
<groupId>com.ververica</groupId> <groupId>com.ververica</groupId>
<artifactId>flink-connector-oracle-cdc</artifactId> <artifactId>flink-sql-connector-oracle-cdc</artifactId>
<version>${flinkcdc.version}</version> <version>${flinkcdc.version}</version>
</dependency> </dependency>
<dependency> <dependency>
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment