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;