You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hudi.apache.org by vi...@apache.org on 2021/01/22 18:56:00 UTC
[hudi] branch master updated: [HOTFIX] Revert upgrade flink verison
to 1.12.0 (#2473)
This is an automated email from the ASF dual-hosted git repository.
vinoth pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git
The following commit(s) were added to refs/heads/master by this push:
new d3ea0f9 [HOTFIX] Revert upgrade flink verison to 1.12.0 (#2473)
d3ea0f9 is described below
commit d3ea0f957e231029c5c21ac479039159aa499cb4
Author: wangxianghu <wx...@126.com>
AuthorDate: Sat Jan 23 02:55:46 2021 +0800
[HOTFIX] Revert upgrade flink verison to 1.12.0 (#2473)
---
packaging/hudi-flink-bundle/pom.xml | 7 +++++++
pom.xml | 2 +-
2 files changed, 8 insertions(+), 1 deletion(-)
diff --git a/packaging/hudi-flink-bundle/pom.xml b/packaging/hudi-flink-bundle/pom.xml
index 076ee43..b8a8cd1 100644
--- a/packaging/hudi-flink-bundle/pom.xml
+++ b/packaging/hudi-flink-bundle/pom.xml
@@ -104,6 +104,7 @@
<include>io.prometheus:simpleclient_common</include>
<include>com.yammer.metrics:metrics-core</include>
<include>org.apache.flink:flink-connector-kafka_${scala.binary.version}</include>
+ <include>org.apache.flink:flink-connector-kafka-base_${scala.binary.version}</include>
<include>org.apache.kafka:kafka_${scala.binary.version}</include>
<include>com.101tec:zkclient</include>
<include>org.apache.kafka:kafka-clients</include>
@@ -189,6 +190,12 @@
<artifactId>flink-connector-kafka_${scala.binary.version}</artifactId>
<scope>compile</scope>
</dependency>
+ <dependency>
+ <groupId>org.apache.flink</groupId>
+ <artifactId>flink-connector-kafka-base_${scala.binary.version}</artifactId>
+ <version>${flink.version}</version>
+ <scope>compile</scope>
+ </dependency>
<!-- Parquet -->
<dependency>
diff --git a/pom.xml b/pom.xml
index 4f8b153..d4e7b6b 100644
--- a/pom.xml
+++ b/pom.xml
@@ -106,7 +106,7 @@
<prometheus.version>0.8.0</prometheus.version>
<http.version>4.4.1</http.version>
<spark.version>${spark2.version}</spark.version>
- <flink.version>1.12.0</flink.version>
+ <flink.version>1.11.2</flink.version>
<spark2.version>2.4.4</spark2.version>
<spark3.version>3.0.0</spark3.version>
<avro.version>1.8.2</avro.version>