diff --git a/austin-data-house/pom.xml b/austin-data-house/pom.xml
index dba1fab..30b5381 100644
--- a/austin-data-house/pom.xml
+++ b/austin-data-house/pom.xml
@@ -23,13 +23,13 @@
         <dependency>
             <groupId>org.apache.flink</groupId>
             <artifactId>flink-connector-hive_2.12</artifactId>
-            <version>${flink.version}</version>
+            <version>1.16.0</version>
             <scope>provided</scope>
         </dependency>
         <dependency>
             <groupId>org.apache.flink</groupId>
             <artifactId>flink-table-api-java-bridge</artifactId>
-            <version>${flink.version}</version>
+            <version>1.16.0</version>
             <scope>provided</scope>
         </dependency>
 
diff --git a/austin-stream/pom.xml b/austin-stream/pom.xml
index f995bf6..3bc7137 100644
--- a/austin-stream/pom.xml
+++ b/austin-stream/pom.xml
@@ -15,27 +15,26 @@
     <dependencies>
         <dependency>
             <groupId>org.apache.flink</groupId>
-            <artifactId>flink-walkthrough-common</artifactId>
+            <artifactId>flink-walkthrough-common_${scala.binary.version}</artifactId>
             <version>${flink.version}</version>
         </dependency>
         <!-- This dependency is provided, because it should not be packaged into the JAR file. -->
         <dependency>
             <groupId>org.apache.flink</groupId>
-            <artifactId>flink-streaming-java</artifactId>
+            <artifactId>flink-streaming-java_${scala.binary.version}</artifactId>
             <version>${flink.version}</version>
             <scope>provided</scope>
         </dependency>
         <dependency>
             <groupId>org.apache.flink</groupId>
-            <artifactId>flink-clients</artifactId>
+            <artifactId>flink-clients_${scala.binary.version}</artifactId>
             <version>${flink.version}</version>
             <scope>provided</scope>
         </dependency>
         <!-- Add connector dependencies here. They must be in the default scope (compile). -->
-
         <dependency>
             <groupId>org.apache.flink</groupId>
-            <artifactId>flink-connector-kafka</artifactId>
+            <artifactId>flink-connector-kafka_${scala.binary.version}</artifactId>
             <version>${flink.version}</version>
         </dependency>
 
@@ -86,7 +85,7 @@
                                     <resource>META-INF/spring.schemas</resource>
                                 </transformer>
                                 <transformer
-                                        implementation="org.apache.maven.plugins.shade.resource.ServicesResourceTransformer"/>
+                                        implementation="org.apache.maven.plugins.shade.resource.ServicesResourceTransformer" />
                                 <transformer
                                         implementation="org.apache.maven.plugins.shade.resource.ManifestResourceTransformer">
                                     <mainClass>com.java3y.austin.stream.AustinBootStrap</mainClass>
diff --git a/austin-stream/src/main/java/com/java3y/austin/stream/constants/AustinFlinkConstant.java b/austin-stream/src/main/java/com/java3y/austin/stream/constants/AustinFlinkConstant.java
index d02afae..7bf2262 100644
--- a/austin-stream/src/main/java/com/java3y/austin/stream/constants/AustinFlinkConstant.java
+++ b/austin-stream/src/main/java/com/java3y/austin/stream/constants/AustinFlinkConstant.java
@@ -22,21 +22,10 @@ public class AustinFlinkConstant {
      * TODO 使用前配置redis ip:port
      * (真实网络ip,这里不能用配置的hosts，看语雀文档得到真实ip)
      */
-
-    public static final String REDIS_MODE_SENTINEL = "SENTINEL";
-
-    public static final String REDIS_MODE_SINGLE = "SINGLE";
-
-    public static final String REDIS_MODE = REDIS_MODE_SENTINEL;
-
     public static final String REDIS_IP = "austin-redis";
-
-    public static final Integer REDIS_PORT = 6379;
-
+    public static final String REDIS_PORT = "6379";
     public static final String REDIS_PASSWORD = "austin";
 
-    public static final String MASTER_ID = "mymaster";
-
 
     /**
      * Flink流程常量
diff --git a/austin-stream/src/main/java/com/java3y/austin/stream/utils/LettuceRedisUtils.java b/austin-stream/src/main/java/com/java3y/austin/stream/utils/LettuceRedisUtils.java
index 7c9269a..0c64cd2 100644
--- a/austin-stream/src/main/java/com/java3y/austin/stream/utils/LettuceRedisUtils.java
+++ b/austin-stream/src/main/java/com/java3y/austin/stream/utils/LettuceRedisUtils.java
@@ -1,6 +1,5 @@
 package com.java3y.austin.stream.utils;
 
-import cn.hutool.core.util.StrUtil;
 import com.java3y.austin.stream.callback.RedisPipelineCallBack;
 import com.java3y.austin.stream.constants.AustinFlinkConstant;
 import io.lettuce.core.LettuceFutures;
@@ -27,18 +26,10 @@ public class LettuceRedisUtils {
     private static RedisClient redisClient;
 
     static {
-        RedisURI redisUri = null;
-        if (StrUtil.equals(AustinFlinkConstant.REDIS_MODE_SENTINEL, AustinFlinkConstant.REDIS_MODE)) {
-            redisUri = RedisURI.Builder.sentinel(AustinFlinkConstant.REDIS_IP, AustinFlinkConstant.MASTER_ID)
-                    .withPassword(AustinFlinkConstant.REDIS_PASSWORD.toCharArray())
-                    .build();
-        } else if (StrUtil.equals(AustinFlinkConstant.REDIS_MODE_SINGLE, AustinFlinkConstant.REDIS_MODE)) {
-            redisUri = RedisURI.Builder.redis(AustinFlinkConstant.REDIS_IP)
-                    .withPort(Integer.valueOf(AustinFlinkConstant.REDIS_PORT))
-                    .withPassword(AustinFlinkConstant.REDIS_PASSWORD.toCharArray())
-                    .build();
-        }
-
+        RedisURI redisUri = RedisURI.Builder.redis(AustinFlinkConstant.REDIS_IP)
+                .withPort(Integer.valueOf(AustinFlinkConstant.REDIS_PORT))
+                .withPassword(AustinFlinkConstant.REDIS_PASSWORD.toCharArray())
+                .build();
         redisClient = RedisClient.create(redisUri);
     }
 
diff --git a/pom.xml b/pom.xml
index 80e2a69..7692650 100644
--- a/pom.xml
+++ b/pom.xml
@@ -32,8 +32,9 @@
     <properties>
         <java.version>1.8</java.version>
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
-        <flink.version>1.17.1</flink.version>
+        <flink.version>1.14.3</flink.version>
         <target.java.version>1.8</target.java.version>
+        <scala.binary.version>2.11</scala.binary.version>
         <maven.compiler.source>${target.java.version}</maven.compiler.source>
         <maven.compiler.target>${target.java.version}</maven.compiler.target>
         <log4j.version>2.17.1</log4j.version>
@@ -53,7 +54,7 @@
             <dependency>
                 <groupId>cn.hutool</groupId>
                 <artifactId>hutool-all</artifactId>
-                <version>5.8.16</version>
+                <version>5.7.15</version>
             </dependency>
 
             <!--guava工具包-->
@@ -134,28 +135,21 @@
                 <version>2.3.0</version>
             </dependency>
 
-            <!--Kafka 消息队列-->
-            <dependency>
-                <groupId>org.apache.kafka</groupId>
-                <artifactId>kafka-clients</artifactId>
-                <version>3.2.3</version>
-            </dependency>
-
             <!--flink相关依赖-->
             <dependency>
                 <groupId>org.apache.flink</groupId>
-                <artifactId>flink-walkthrough-common</artifactId>
+                <artifactId>flink-walkthrough-common_${scala.binary.version}</artifactId>
                 <version>${flink.version}</version>
             </dependency>
             <dependency>
                 <groupId>org.apache.flink</groupId>
-                <artifactId>flink-streaming-java</artifactId>
+                <artifactId>flink-streaming-java_${scala.binary.version}</artifactId>
                 <version>${flink.version}</version>
                 <scope>provided</scope>
             </dependency>
             <dependency>
                 <groupId>org.apache.flink</groupId>
-                <artifactId>flink-clients</artifactId>
+                <artifactId>flink-clients_${scala.binary.version}</artifactId>
                 <version>${flink.version}</version>
                 <scope>provided</scope>
             </dependency>
@@ -163,7 +157,7 @@
             <!--kafkaFlink连接器-->
             <dependency>
                 <groupId>org.apache.flink</groupId>
-                <artifactId>flink-connector-kafka</artifactId>
+                <artifactId>flink-connector-kafka_${scala.binary.version}</artifactId>
                 <version>${flink.version}</version>
             </dependency>