diff --git a/docs/compile.md b/docs/compile.md
index f5189132..13b0cc8d 100644
--- a/docs/compile.md
+++ b/docs/compile.md
@@ -1,4 +1,4 @@
-目前web客户端支持的flink版本是1.15.3,如果需要调整flink版本可下载源码
+目前web客户端支持的flink版本是1.16.2,如果需要调整flink版本可下载源码
 然后修改pom里面的版本号 https://github.com/zhp8341/flink-streaming-platform-web/blob/master/pom.xml 
 ~~~~
 <flink.version>1.12.0</flink.version> <!--flink版本-->
diff --git a/docs/deploy.md b/docs/deploy.md
index fa4eca19..ff736eb1 100644
--- a/docs/deploy.md
+++ b/docs/deploy.md
@@ -9,7 +9,7 @@ hadoop版本 2+
 
 jdk版本 jdk1.8
 
-scala版本 2.11  
+scala版本 2.12  
 
 kafka版本 1.0+
 
@@ -23,11 +23,11 @@ mysql版本 5.6+
 
 #### 1、flink客户端安装
 
-下载对应版本 
-https://www.apache.org/dyn/closer.lua/flink/flink-1.15.3/flink-1.15.3-bin-scala_2.11.tgz 然后解压
+下载对应版本
+https://www.apache.org/dyn/closer.lua/flink/flink-1.16.2/flink-1.16.2-bin-scala_2.12.tgz 然后解压
 
 
-a: /flink-1.15.3/conf  
+a: /flink-1.16.2/conf  
 
 **1、YARN_PER模式** 
 
diff --git a/docs/idea-run.md b/docs/idea-run.md
index 9e7434ab..4b4a6b05 100644
--- a/docs/idea-run.md
+++ b/docs/idea-run.md
@@ -22,13 +22,13 @@
 
 8、flink-streaming-web 模块是REST服务模块，运行启动类是：com.flink.streaming.web.StartApplication
 
-9、启动完成后，访问本地: localhost:8080   用户名: admin  密码: 123456
+9、启动完成后，访问本地: localhost:8180   用户名: admin  密码: 123456
 
 10、系统设置：flink_streaming_platform_web_home=你自己的路径/flink-streaming-platform-web/
 
-11、如果你开发环境有 YARN 就配置 yarn_rm_http_address  (根据你自己的确定)
+11、本地启动flink集群./start-cluster.sh 并在系统配置中 flink_rest_http_address为http://localhost:8180/
 
-12、如果是standalone模式，需要本地运行Flink 集群，并配置 flink_rest_http_address
+12、创建任务,并设置运行模式为Local Cluster，然后就可以愉快的写sql了
 ```
 
 ## 原理
diff --git a/flink-streaming-core/src/test/java/Demo.java b/flink-streaming-core/src/test/java/Demo.java
index dced9086..fc45862d 100644
--- a/flink-streaming-core/src/test/java/Demo.java
+++ b/flink-streaming-core/src/test/java/Demo.java
@@ -10,8 +10,8 @@
 
 public class Demo {
 
-
-  private static String test_sql_file = "/Users/edy/git/flink-streaming-platform-web/flink-streaming-core/src/test.sql";
+  private static String test_sql_file = "/Users/liquan/workspace/git_project/flink-streaming-platform-web/flink-streaming-core/src/test.sql";
+//  private static String test_sql_file = "/Users/edy/git/flink-streaming-platform-web/flink-streaming-core/src/test.sql";
 
 
   public static void main(String[] args) throws Exception {
diff --git a/flink-streaming-validation/src/test/java/com/flink/streaming/sql/validation/test/TestSqlValidation.java b/flink-streaming-validation/src/test/java/com/flink/streaming/sql/validation/test/TestSqlValidation.java
index e39270b5..0a073be6 100644
--- a/flink-streaming-validation/src/test/java/com/flink/streaming/sql/validation/test/TestSqlValidation.java
+++ b/flink-streaming-validation/src/test/java/com/flink/streaming/sql/validation/test/TestSqlValidation.java
@@ -17,7 +17,8 @@
  */
 public class TestSqlValidation {
 
-  private static String test_sql_file = "/Users/edy/git/flink-streaming-platform-web/flink-streaming-core/src/hive-test.sql";
+  private static String test_sql_file = "/Users/liquan/workspace/git_project/flink-streaming-platform-web/flink-streaming-core/src/hive-test.sql";
+//  private static String test_sql_file = "/Users/edy/git/flink-streaming-platform-web/flink-streaming-core/src/hive-test.sql";
 
   @Test
   public void checkSql() throws IOException {
diff --git a/flink-streaming-web/pom.xml b/flink-streaming-web/pom.xml
index 32542429..26272738 100644
--- a/flink-streaming-web/pom.xml
+++ b/flink-streaming-web/pom.xml
@@ -14,7 +14,7 @@
   <version>1.5.0.RELEASE</version>
 
   <properties>
-    <nacos.config.version>0.2.7</nacos.config.version>
+    <nacos.config.version>0.2.8</nacos.config.version>
   </properties>
 
   <dependencies>
diff --git a/pom.xml b/pom.xml
index 9d03c132..a1dbff74 100644
--- a/pom.xml
+++ b/pom.xml
@@ -38,7 +38,7 @@
         <java_target_version>1.8</java_target_version>
         <file_encoding>UTF-8</file_encoding>
         <flink_streaming_version>1.5.0.RELEASE</flink_streaming_version>
-        <flink.version>1.15.3</flink.version>
+        <flink.version>1.16.2</flink.version>
         <scala.binary.version>2.12</scala.binary.version>
         <spring.boot.version>2.2.8.RELEASE</spring.boot.version>
     </properties>