From f9d7983671b2faaa86b276633e8799f46f2f4cd0 Mon Sep 17 00:00:00 2001
From: DongLiang-0 <46414265+DongLiang-0@users.noreply.github.com>
Date: Fri, 2 Dec 2022 10:18:27 +0800
Subject: [PATCH] [fix](doris-demo)fix flink-connector demo maven dependency
 conflict (#14714)

---
 samples/doris-demo/flink-demo-v1.1/pom.xml                      | 2 +-
 samples/doris-demo/pom.xml                                      | 1 +
 .../doris/demo/spark/demo/hdfs/MyForeachPartitionFunction.java  | 2 ++
 3 files changed, 4 insertions(+), 1 deletion(-)

diff --git a/samples/doris-demo/flink-demo-v1.1/pom.xml b/samples/doris-demo/flink-demo-v1.1/pom.xml
index 156483165b..c1e00ea318 100644
--- a/samples/doris-demo/flink-demo-v1.1/pom.xml
+++ b/samples/doris-demo/flink-demo-v1.1/pom.xml
@@ -95,7 +95,7 @@ under the License.
         </dependency>
         <dependency>
             <groupId>com.ververica</groupId>
-            <artifactId>flink-connector-mysql-cdc</artifactId>
+            <artifactId>flink-sql-connector-mysql-cdc</artifactId>
             <version>2.2.1</version>
             <exclusions>
                 <exclusion>
diff --git a/samples/doris-demo/pom.xml b/samples/doris-demo/pom.xml
index 3b196633fa..e94b74402d 100644
--- a/samples/doris-demo/pom.xml
+++ b/samples/doris-demo/pom.xml
@@ -26,6 +26,7 @@ under the License.
     <version>1.0-SNAPSHOT</version>
     <modules>
         <module>flink-demo</module>
+        <module>flink-demo-v1.1</module>
         <module>spark-demo</module>
         <module>stream-load-demo</module>
         <module>spring-jdbc-demo</module>
diff --git a/samples/doris-demo/spark-demo/src/main/java/org/apache/doris/demo/spark/demo/hdfs/MyForeachPartitionFunction.java b/samples/doris-demo/spark-demo/src/main/java/org/apache/doris/demo/spark/demo/hdfs/MyForeachPartitionFunction.java
index 8947a32615..1ef9ee3596 100644
--- a/samples/doris-demo/spark-demo/src/main/java/org/apache/doris/demo/spark/demo/hdfs/MyForeachPartitionFunction.java
+++ b/samples/doris-demo/spark-demo/src/main/java/org/apache/doris/demo/spark/demo/hdfs/MyForeachPartitionFunction.java
@@ -22,6 +22,8 @@ import com.alibaba.fastjson.JSONArray;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.doris.demo.spark.util.DorisStreamLoad;
 import org.apache.doris.demo.spark.vo.TestVo;
+
+import scala.Function1;
 import scala.runtime.AbstractFunction1;
 import scala.collection.AbstractIterator;