From d3ea0f957e231029c5c21ac479039159aa499cb4 Mon Sep 17 00:00:00 2001
From: wangxianghu <wxhjsxz@126.com>
Date: Sat, 23 Jan 2021 02:55:46 +0800
Subject: [PATCH] [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 076ee433c..b8a8cd1ef 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 4f8b153bf..d4e7b6bdf 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>