From 2050645696bda55c31bf3f6bd76a4924aa6dc166 Mon Sep 17 00:00:00 2001
From: benjobs <benjobs@apache.org>
Date: Mon, 13 Jan 2025 21:49:44 +0800
Subject: [PATCH] [Improve] update version to 2.1.6

---
 build.sh                                                      | 2 +-
 docker/README.md                                              | 2 +-
 docker/docker-compose.yaml                                    | 2 +-
 helm/streampark/Chart.yaml                                    | 4 ++--
 helm/streampark/values.yaml                                   | 2 +-
 pom.xml                                                       | 2 +-
 streampark-common/pom.xml                                     | 2 +-
 .../scala/org/apache/streampark/common/conf/ConfigConst.scala | 2 +-
 streampark-console/pom.xml                                    | 2 +-
 streampark-console/streampark-console-service/pom.xml         | 2 +-
 .../src/main/assembly/bin/streampark.sh                       | 2 +-
 .../streampark/console/system/runner/StartedUpRunner.java     | 2 +-
 streampark-console/streampark-console-webapp/package.json     | 2 +-
 streampark-flink/pom.xml                                      | 2 +-
 streampark-flink/streampark-flink-client/pom.xml              | 2 +-
 .../streampark-flink-client-api/pom.xml                       | 2 +-
 .../streampark-flink-client-core/pom.xml                      | 2 +-
 streampark-flink/streampark-flink-connector/pom.xml           | 2 +-
 .../streampark-flink-connector-base/pom.xml                   | 2 +-
 .../streampark-flink-connector-clickhouse/pom.xml             | 2 +-
 .../streampark-flink-connector-doris/pom.xml                  | 2 +-
 .../streampark-flink-connector-elasticsearch/pom.xml          | 2 +-
 .../streampark-flink-connector-elasticsearch5/pom.xml         | 2 +-
 .../streampark-flink-connector-elasticsearch6/pom.xml         | 2 +-
 .../streampark-flink-connector-elasticsearch7/pom.xml         | 2 +-
 .../streampark-flink-connector-hbase/pom.xml                  | 2 +-
 .../streampark-flink-connector-http/pom.xml                   | 2 +-
 .../streampark-flink-connector-influx/pom.xml                 | 2 +-
 .../streampark-flink-connector-jdbc/pom.xml                   | 2 +-
 .../streampark-flink-connector-kafka/pom.xml                  | 2 +-
 .../streampark-flink-connector-mongo/pom.xml                  | 2 +-
 .../streampark-flink-connector-redis/pom.xml                  | 2 +-
 streampark-flink/streampark-flink-core/pom.xml                | 2 +-
 streampark-flink/streampark-flink-kubernetes/pom.xml          | 2 +-
 streampark-flink/streampark-flink-packer/pom.xml              | 2 +-
 streampark-flink/streampark-flink-proxy/pom.xml               | 2 +-
 streampark-flink/streampark-flink-shims/pom.xml               | 2 +-
 .../streampark-flink-shims-base/pom.xml                       | 2 +-
 .../streampark-flink-shims-test/pom.xml                       | 2 +-
 .../streampark-flink-shims_flink-1.12/pom.xml                 | 2 +-
 .../streampark-flink-shims_flink-1.13/pom.xml                 | 2 +-
 .../streampark-flink-shims_flink-1.14/pom.xml                 | 2 +-
 .../streampark-flink-shims_flink-1.15/pom.xml                 | 2 +-
 .../streampark-flink-shims_flink-1.16/pom.xml                 | 2 +-
 .../streampark-flink-shims_flink-1.17/pom.xml                 | 2 +-
 .../streampark-flink-shims_flink-1.18/pom.xml                 | 2 +-
 .../streampark-flink-shims_flink-1.19/pom.xml                 | 2 +-
 .../streampark-flink-shims_flink-1.20/pom.xml                 | 2 +-
 streampark-flink/streampark-flink-sqlclient/pom.xml           | 2 +-
 streampark-flink/streampark-flink-udf/pom.xml                 | 2 +-
 streampark-shaded/pom.xml                                     | 2 +-
 streampark-spark/pom.xml                                      | 2 +-
 streampark-spark/streampark-spark-cli/pom.xml                 | 2 +-
 streampark-spark/streampark-spark-connector/pom.xml           | 2 +-
 .../streampark-spark-connector-base/pom.xml                   | 2 +-
 .../streampark-spark-connector-kafka/pom.xml                  | 2 +-
 streampark-spark/streampark-spark-core/pom.xml                | 2 +-
 57 files changed, 58 insertions(+), 58 deletions(-)

diff --git a/build.sh b/build.sh
index bc46099a2b..b0d937769a 100755
--- a/build.sh
+++ b/build.sh
@@ -116,7 +116,7 @@ print_logo() {
   printf '      %s  ___/ / /_/ /  /  __/ /_/ / / / / / / /_/ / /_/ / /  / ,<        %s\n'          $PRIMARY $RESET
   printf '      %s /____/\__/_/   \___/\__,_/_/ /_/ /_/ ____/\__,_/_/  /_/|_|       %s\n'          $PRIMARY $RESET
   printf '      %s                                   /_/                            %s\n\n'        $PRIMARY $RESET
-  printf '      %s   Version:  2.1.5 %s\n'                                                $BLUE   $RESET
+  printf '      %s   Version:  2.1.6 %s\n'                                                $BLUE   $RESET
   printf '      %s   WebSite:  https://streampark.apache.org%s\n'                                  $BLUE   $RESET
   printf '      %s   GitHub :  http://github.com/apache/streampark%s\n\n'                          $BLUE   $RESET
   printf '      %s   ──────── Apache StreamPark, Make stream processing easier ô~ô!%s\n\n'         $PRIMARY  $RESET
diff --git a/docker/README.md b/docker/README.md
index d74b966fd2..ce079c4bda 100644
--- a/docker/README.md
+++ b/docker/README.md
@@ -7,7 +7,7 @@ The latest image tag will be written to [docker-compose.yaml](./docker-compose.y
 version: '3.8'
 services:
     streampark:
-        image: apache/streampark:2.1.5
+        image: apache/streampark:2.1.6
 ```
 
 ### 2. docker-compose up
diff --git a/docker/docker-compose.yaml b/docker/docker-compose.yaml
index dbbdc804e9..026e9d7d2a 100644
--- a/docker/docker-compose.yaml
+++ b/docker/docker-compose.yaml
@@ -18,7 +18,7 @@ version: '3.8'
 
 services:
   streampark:
-    image: apache/streampark:2.1.5
+    image: apache/streampark:2.1.6
     ports:
       - "10000:10000"
     environment:
diff --git a/helm/streampark/Chart.yaml b/helm/streampark/Chart.yaml
index 7aa2ff62b4..e2bc774a97 100644
--- a/helm/streampark/Chart.yaml
+++ b/helm/streampark/Chart.yaml
@@ -20,5 +20,5 @@ description: A Helm chart for the Apache StreamPark
 home: https://streampark.apache.org
 icon: https://streampark.apache.org/image/logo_name.png
 type: application
-version: 2.1.5
-appVersion: 2.1.5
+version: 2.1.6
+appVersion: 2.1.6
diff --git a/helm/streampark/values.yaml b/helm/streampark/values.yaml
index ea47e0d55b..a610e43fd5 100644
--- a/helm/streampark/values.yaml
+++ b/helm/streampark/values.yaml
@@ -18,7 +18,7 @@
 image:
   repository: "apache/streampark"
   pullPolicy: "IfNotPresent"
-  tag: "2.1.5"
+  tag: "2.1.6"
   pullSecret: ""
 
 rbac:
diff --git a/pom.xml b/pom.xml
index 55ee8f027e..b5babe3a69 100644
--- a/pom.xml
+++ b/pom.xml
@@ -26,7 +26,7 @@
 
     <groupId>org.apache.streampark</groupId>
     <artifactId>streampark</artifactId>
-    <version>2.1.5</version>
+    <version>2.1.6</version>
     <packaging>pom</packaging>
     <name>StreamPark Project Parent POM</name>
 
diff --git a/streampark-common/pom.xml b/streampark-common/pom.xml
index a593a1bbbe..3fc00a3880 100644
--- a/streampark-common/pom.xml
+++ b/streampark-common/pom.xml
@@ -21,7 +21,7 @@
     <parent>
         <groupId>org.apache.streampark</groupId>
         <artifactId>streampark</artifactId>
-        <version>2.1.5</version>
+        <version>2.1.6</version>
     </parent>
 
     <artifactId>streampark-common_${scala.binary.version}</artifactId>
diff --git a/streampark-common/src/main/scala/org/apache/streampark/common/conf/ConfigConst.scala b/streampark-common/src/main/scala/org/apache/streampark/common/conf/ConfigConst.scala
index f60151c9f0..4d3acefb8f 100644
--- a/streampark-common/src/main/scala/org/apache/streampark/common/conf/ConfigConst.scala
+++ b/streampark-common/src/main/scala/org/apache/streampark/common/conf/ConfigConst.scala
@@ -203,7 +203,7 @@ object ConfigConst {
     println("      ___/ / /_/ /  /  __/ /_/ / / / / / / /_/ / /_/ / /  / ,<        ")
     println("     /____/\\__/_/   \\___/\\__,_/_/ /_/ /_/ ____/\\__,_/_/  /_/|_|   ")
     println("                                       /_/                        \n\n")
-    println("    Version:  2.1.5                                          ")
+    println("    Version:  2.1.6                                          ")
     println("    WebSite:  https://streampark.apache.org                           ")
     println("    GitHub :  https://github.com/apache/incubator-streampark                    ")
     println(s"    Info   :  $info                                 ")
diff --git a/streampark-console/pom.xml b/streampark-console/pom.xml
index 55e33dff42..6840e1f9e7 100644
--- a/streampark-console/pom.xml
+++ b/streampark-console/pom.xml
@@ -22,7 +22,7 @@
     <parent>
         <groupId>org.apache.streampark</groupId>
         <artifactId>streampark</artifactId>
-        <version>2.1.5</version>
+        <version>2.1.6</version>
     </parent>
 
     <artifactId>streampark-console</artifactId>
diff --git a/streampark-console/streampark-console-service/pom.xml b/streampark-console/streampark-console-service/pom.xml
index 0f8f5ddf77..b9ce5868a2 100644
--- a/streampark-console/streampark-console-service/pom.xml
+++ b/streampark-console/streampark-console-service/pom.xml
@@ -23,7 +23,7 @@
     <parent>
         <groupId>org.apache.streampark</groupId>
         <artifactId>streampark-console</artifactId>
-        <version>2.1.5</version>
+        <version>2.1.6</version>
     </parent>
 
     <artifactId>streampark-console-service</artifactId>
diff --git a/streampark-console/streampark-console-service/src/main/assembly/bin/streampark.sh b/streampark-console/streampark-console-service/src/main/assembly/bin/streampark.sh
index e534658201..70fb61b8a5 100755
--- a/streampark-console/streampark-console-service/src/main/assembly/bin/streampark.sh
+++ b/streampark-console/streampark-console-service/src/main/assembly/bin/streampark.sh
@@ -297,7 +297,7 @@ print_logo() {
   printf '      %s  ___/ / /_/ /  /  __/ /_/ / / / / / / /_/ / /_/ / /  / ,<        %s\n'          $PRIMARY $RESET
   printf '      %s /____/\__/_/   \___/\__,_/_/ /_/ /_/ ____/\__,_/_/  /_/|_|       %s\n'          $PRIMARY $RESET
   printf '      %s                                   /_/                            %s\n\n'        $PRIMARY $RESET
-  printf '      %s   Version:  2.1.5 %s\n'                                                         $BLUE   $RESET
+  printf '      %s   Version:  2.1.6 %s\n'                                                         $BLUE   $RESET
   printf '      %s   WebSite:  https://streampark.apache.org%s\n'                                  $BLUE   $RESET
   printf '      %s   GitHub :  http://github.com/apache/streampark%s\n\n'                          $BLUE   $RESET
   printf '      %s   ──────── Apache StreamPark, Make stream processing easier ô~ô!%s\n\n'         $PRIMARY  $RESET
diff --git a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/runner/StartedUpRunner.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/runner/StartedUpRunner.java
index 2b94e467a2..0916823d52 100644
--- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/runner/StartedUpRunner.java
+++ b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/runner/StartedUpRunner.java
@@ -47,7 +47,7 @@ public void run(ApplicationArguments args) {
       System.out.println("      ___/ / /_/ /  /  __/ /_/ / / / / / / /_/ / /_/ / /  / ,<        ");
       System.out.println("     /____/\\__/_/   \\___/\\__,_/_/ /_/ /_/ ____/\\__,_/_/  /_/|_|   ");
       System.out.println("                                       /_/                        \n\n");
-      System.out.println("    Version:  2.1.5                                                   ");
+      System.out.println("    Version:  2.1.6                                                   ");
       System.out.println("    WebSite:  https://streampark.apache.org                           ");
       System.out.println("    GitHub :  https://github.com/apache/incubator-streampark          ");
       System.out.println("    Info   :  streampark-console start successful                     ");
diff --git a/streampark-console/streampark-console-webapp/package.json b/streampark-console/streampark-console-webapp/package.json
index f161262337..9809581b12 100644
--- a/streampark-console/streampark-console-webapp/package.json
+++ b/streampark-console/streampark-console-webapp/package.json
@@ -1,6 +1,6 @@
 {
   "name": "streampark-webapp",
-  "version": "2.1.5",
+  "version": "2.1.6",
   "author": {
     "name": "streampark",
     "url": "https://streampark.apache.org"
diff --git a/streampark-flink/pom.xml b/streampark-flink/pom.xml
index 12e4944a08..fb00fe5dbc 100644
--- a/streampark-flink/pom.xml
+++ b/streampark-flink/pom.xml
@@ -21,7 +21,7 @@
     <parent>
         <groupId>org.apache.streampark</groupId>
         <artifactId>streampark</artifactId>
-        <version>2.1.5</version>
+        <version>2.1.6</version>
     </parent>
 
     <artifactId>streampark-flink</artifactId>
diff --git a/streampark-flink/streampark-flink-client/pom.xml b/streampark-flink/streampark-flink-client/pom.xml
index 5e14c6f790..1202565bdf 100644
--- a/streampark-flink/streampark-flink-client/pom.xml
+++ b/streampark-flink/streampark-flink-client/pom.xml
@@ -20,7 +20,7 @@
     <parent>
         <groupId>org.apache.streampark</groupId>
         <artifactId>streampark-flink</artifactId>
-        <version>2.1.5</version>
+        <version>2.1.6</version>
     </parent>
 
     <artifactId>streampark-flink-client</artifactId>
diff --git a/streampark-flink/streampark-flink-client/streampark-flink-client-api/pom.xml b/streampark-flink/streampark-flink-client/streampark-flink-client-api/pom.xml
index c0b18454c8..afb98c680f 100644
--- a/streampark-flink/streampark-flink-client/streampark-flink-client-api/pom.xml
+++ b/streampark-flink/streampark-flink-client/streampark-flink-client-api/pom.xml
@@ -20,7 +20,7 @@
     <parent>
         <groupId>org.apache.streampark</groupId>
         <artifactId>streampark-flink-client</artifactId>
-        <version>2.1.5</version>
+        <version>2.1.6</version>
     </parent>
 
     <artifactId>streampark-flink-client-api_${scala.binary.version}</artifactId>
diff --git a/streampark-flink/streampark-flink-client/streampark-flink-client-core/pom.xml b/streampark-flink/streampark-flink-client/streampark-flink-client-core/pom.xml
index 4eea4c42e0..2e642312da 100644
--- a/streampark-flink/streampark-flink-client/streampark-flink-client-core/pom.xml
+++ b/streampark-flink/streampark-flink-client/streampark-flink-client-core/pom.xml
@@ -20,7 +20,7 @@
     <parent>
         <groupId>org.apache.streampark</groupId>
         <artifactId>streampark-flink-client</artifactId>
-        <version>2.1.5</version>
+        <version>2.1.6</version>
     </parent>
 
     <artifactId>streampark-flink-client-core_${scala.binary.version}</artifactId>
diff --git a/streampark-flink/streampark-flink-connector/pom.xml b/streampark-flink/streampark-flink-connector/pom.xml
index 1a721bf6d9..a11921c3de 100644
--- a/streampark-flink/streampark-flink-connector/pom.xml
+++ b/streampark-flink/streampark-flink-connector/pom.xml
@@ -21,7 +21,7 @@
     <parent>
         <groupId>org.apache.streampark</groupId>
         <artifactId>streampark-flink</artifactId>
-        <version>2.1.5</version>
+        <version>2.1.6</version>
     </parent>
 
     <artifactId>streampark-flink-connector</artifactId>
diff --git a/streampark-flink/streampark-flink-connector/streampark-flink-connector-base/pom.xml b/streampark-flink/streampark-flink-connector/streampark-flink-connector-base/pom.xml
index b3d784c24e..4736d05175 100644
--- a/streampark-flink/streampark-flink-connector/streampark-flink-connector-base/pom.xml
+++ b/streampark-flink/streampark-flink-connector/streampark-flink-connector-base/pom.xml
@@ -21,7 +21,7 @@
     <parent>
         <groupId>org.apache.streampark</groupId>
         <artifactId>streampark-flink-connector</artifactId>
-        <version>2.1.5</version>
+        <version>2.1.6</version>
     </parent>
 
     <artifactId>streampark-flink-connector-base_${scala.binary.version}</artifactId>
diff --git a/streampark-flink/streampark-flink-connector/streampark-flink-connector-clickhouse/pom.xml b/streampark-flink/streampark-flink-connector/streampark-flink-connector-clickhouse/pom.xml
index b7242b4df4..95f02c2677 100644
--- a/streampark-flink/streampark-flink-connector/streampark-flink-connector-clickhouse/pom.xml
+++ b/streampark-flink/streampark-flink-connector/streampark-flink-connector-clickhouse/pom.xml
@@ -21,7 +21,7 @@
     <parent>
         <groupId>org.apache.streampark</groupId>
         <artifactId>streampark-flink-connector</artifactId>
-        <version>2.1.5</version>
+        <version>2.1.6</version>
     </parent>
 
     <artifactId>streampark-flink-connector-clickhouse_${scala.binary.version}</artifactId>
diff --git a/streampark-flink/streampark-flink-connector/streampark-flink-connector-doris/pom.xml b/streampark-flink/streampark-flink-connector/streampark-flink-connector-doris/pom.xml
index 04dc4e1196..fe520ed3c8 100644
--- a/streampark-flink/streampark-flink-connector/streampark-flink-connector-doris/pom.xml
+++ b/streampark-flink/streampark-flink-connector/streampark-flink-connector-doris/pom.xml
@@ -21,7 +21,7 @@
     <parent>
         <groupId>org.apache.streampark</groupId>
         <artifactId>streampark-flink-connector</artifactId>
-        <version>2.1.5</version>
+        <version>2.1.6</version>
     </parent>
 
     <artifactId>streampark-flink-connector-doris_${scala.binary.version}</artifactId>
diff --git a/streampark-flink/streampark-flink-connector/streampark-flink-connector-elasticsearch/pom.xml b/streampark-flink/streampark-flink-connector/streampark-flink-connector-elasticsearch/pom.xml
index 739093d8a5..caaefd7a29 100644
--- a/streampark-flink/streampark-flink-connector/streampark-flink-connector-elasticsearch/pom.xml
+++ b/streampark-flink/streampark-flink-connector/streampark-flink-connector-elasticsearch/pom.xml
@@ -22,7 +22,7 @@
     <parent>
         <groupId>org.apache.streampark</groupId>
         <artifactId>streampark-flink-connector</artifactId>
-        <version>2.1.5</version>
+        <version>2.1.6</version>
     </parent>
 
     <artifactId>streampark-flink-connector-elasticsearch</artifactId>
diff --git a/streampark-flink/streampark-flink-connector/streampark-flink-connector-elasticsearch/streampark-flink-connector-elasticsearch5/pom.xml b/streampark-flink/streampark-flink-connector/streampark-flink-connector-elasticsearch/streampark-flink-connector-elasticsearch5/pom.xml
index aae740241a..529b7ca2ee 100644
--- a/streampark-flink/streampark-flink-connector/streampark-flink-connector-elasticsearch/streampark-flink-connector-elasticsearch5/pom.xml
+++ b/streampark-flink/streampark-flink-connector/streampark-flink-connector-elasticsearch/streampark-flink-connector-elasticsearch5/pom.xml
@@ -23,7 +23,7 @@
     <parent>
         <groupId>org.apache.streampark</groupId>
         <artifactId>streampark-flink-connector-elasticsearch</artifactId>
-        <version>2.1.5</version>
+        <version>2.1.6</version>
     </parent>
 
     <artifactId>streampark-flink-connector-elasticsearch5_${scala.binary.version}</artifactId>
diff --git a/streampark-flink/streampark-flink-connector/streampark-flink-connector-elasticsearch/streampark-flink-connector-elasticsearch6/pom.xml b/streampark-flink/streampark-flink-connector/streampark-flink-connector-elasticsearch/streampark-flink-connector-elasticsearch6/pom.xml
index 2bfe0fbec3..d6edc8ebd8 100644
--- a/streampark-flink/streampark-flink-connector/streampark-flink-connector-elasticsearch/streampark-flink-connector-elasticsearch6/pom.xml
+++ b/streampark-flink/streampark-flink-connector/streampark-flink-connector-elasticsearch/streampark-flink-connector-elasticsearch6/pom.xml
@@ -23,7 +23,7 @@
     <parent>
         <groupId>org.apache.streampark</groupId>
         <artifactId>streampark-flink-connector-elasticsearch</artifactId>
-        <version>2.1.5</version>
+        <version>2.1.6</version>
     </parent>
 
     <artifactId>streampark-flink-connector-elasticsearch6_${scala.binary.version}</artifactId>
diff --git a/streampark-flink/streampark-flink-connector/streampark-flink-connector-elasticsearch/streampark-flink-connector-elasticsearch7/pom.xml b/streampark-flink/streampark-flink-connector/streampark-flink-connector-elasticsearch/streampark-flink-connector-elasticsearch7/pom.xml
index 77d3404f56..86482e84f9 100644
--- a/streampark-flink/streampark-flink-connector/streampark-flink-connector-elasticsearch/streampark-flink-connector-elasticsearch7/pom.xml
+++ b/streampark-flink/streampark-flink-connector/streampark-flink-connector-elasticsearch/streampark-flink-connector-elasticsearch7/pom.xml
@@ -22,7 +22,7 @@
     <parent>
         <artifactId>streampark-flink-connector-elasticsearch</artifactId>
         <groupId>org.apache.streampark</groupId>
-        <version>2.1.5</version>
+        <version>2.1.6</version>
     </parent>
 
     <artifactId>streampark-flink-connector-elasticsearch7_${scala.binary.version}</artifactId>
diff --git a/streampark-flink/streampark-flink-connector/streampark-flink-connector-hbase/pom.xml b/streampark-flink/streampark-flink-connector/streampark-flink-connector-hbase/pom.xml
index 94ac922036..828f7e80d6 100644
--- a/streampark-flink/streampark-flink-connector/streampark-flink-connector-hbase/pom.xml
+++ b/streampark-flink/streampark-flink-connector/streampark-flink-connector-hbase/pom.xml
@@ -20,7 +20,7 @@
     <parent>
         <groupId>org.apache.streampark</groupId>
         <artifactId>streampark-flink-connector</artifactId>
-        <version>2.1.5</version>
+        <version>2.1.6</version>
     </parent>
 
     <artifactId>streampark-flink-connector-hbase_${scala.binary.version}</artifactId>
diff --git a/streampark-flink/streampark-flink-connector/streampark-flink-connector-http/pom.xml b/streampark-flink/streampark-flink-connector/streampark-flink-connector-http/pom.xml
index 912f2bb1a5..3e511f41ee 100644
--- a/streampark-flink/streampark-flink-connector/streampark-flink-connector-http/pom.xml
+++ b/streampark-flink/streampark-flink-connector/streampark-flink-connector-http/pom.xml
@@ -20,7 +20,7 @@
     <parent>
         <groupId>org.apache.streampark</groupId>
         <artifactId>streampark-flink-connector</artifactId>
-        <version>2.1.5</version>
+        <version>2.1.6</version>
     </parent>
 
     <artifactId>streampark-flink-connector-http_${scala.binary.version}</artifactId>
diff --git a/streampark-flink/streampark-flink-connector/streampark-flink-connector-influx/pom.xml b/streampark-flink/streampark-flink-connector/streampark-flink-connector-influx/pom.xml
index eb2693317b..5685df8214 100644
--- a/streampark-flink/streampark-flink-connector/streampark-flink-connector-influx/pom.xml
+++ b/streampark-flink/streampark-flink-connector/streampark-flink-connector-influx/pom.xml
@@ -20,7 +20,7 @@
     <parent>
         <groupId>org.apache.streampark</groupId>
         <artifactId>streampark-flink-connector</artifactId>
-        <version>2.1.5</version>
+        <version>2.1.6</version>
     </parent>
 
     <artifactId>streampark-flink-connector-influx_${scala.binary.version}</artifactId>
diff --git a/streampark-flink/streampark-flink-connector/streampark-flink-connector-jdbc/pom.xml b/streampark-flink/streampark-flink-connector/streampark-flink-connector-jdbc/pom.xml
index 5b97fd005c..10858dddf3 100644
--- a/streampark-flink/streampark-flink-connector/streampark-flink-connector-jdbc/pom.xml
+++ b/streampark-flink/streampark-flink-connector/streampark-flink-connector-jdbc/pom.xml
@@ -20,7 +20,7 @@
     <parent>
         <groupId>org.apache.streampark</groupId>
         <artifactId>streampark-flink-connector</artifactId>
-        <version>2.1.5</version>
+        <version>2.1.6</version>
     </parent>
 
     <artifactId>streampark-flink-connector-jdbc_${scala.binary.version}</artifactId>
diff --git a/streampark-flink/streampark-flink-connector/streampark-flink-connector-kafka/pom.xml b/streampark-flink/streampark-flink-connector/streampark-flink-connector-kafka/pom.xml
index 54860efa4b..edc32dccfb 100644
--- a/streampark-flink/streampark-flink-connector/streampark-flink-connector-kafka/pom.xml
+++ b/streampark-flink/streampark-flink-connector/streampark-flink-connector-kafka/pom.xml
@@ -20,7 +20,7 @@
     <parent>
         <groupId>org.apache.streampark</groupId>
         <artifactId>streampark-flink-connector</artifactId>
-        <version>2.1.5</version>
+        <version>2.1.6</version>
     </parent>
 
     <artifactId>streampark-flink-connector-kafka_${scala.binary.version}</artifactId>
diff --git a/streampark-flink/streampark-flink-connector/streampark-flink-connector-mongo/pom.xml b/streampark-flink/streampark-flink-connector/streampark-flink-connector-mongo/pom.xml
index b1c4d26223..449f70414d 100644
--- a/streampark-flink/streampark-flink-connector/streampark-flink-connector-mongo/pom.xml
+++ b/streampark-flink/streampark-flink-connector/streampark-flink-connector-mongo/pom.xml
@@ -20,7 +20,7 @@
     <parent>
         <groupId>org.apache.streampark</groupId>
         <artifactId>streampark-flink-connector</artifactId>
-        <version>2.1.5</version>
+        <version>2.1.6</version>
     </parent>
 
     <artifactId>streampark-flink-connector-mongo_${scala.binary.version}</artifactId>
diff --git a/streampark-flink/streampark-flink-connector/streampark-flink-connector-redis/pom.xml b/streampark-flink/streampark-flink-connector/streampark-flink-connector-redis/pom.xml
index 0e2d33d0da..0606193e1b 100644
--- a/streampark-flink/streampark-flink-connector/streampark-flink-connector-redis/pom.xml
+++ b/streampark-flink/streampark-flink-connector/streampark-flink-connector-redis/pom.xml
@@ -21,7 +21,7 @@
     <parent>
         <groupId>org.apache.streampark</groupId>
         <artifactId>streampark-flink-connector</artifactId>
-        <version>2.1.5</version>
+        <version>2.1.6</version>
     </parent>
 
     <artifactId>streampark-flink-connector-redis_${scala.binary.version}</artifactId>
diff --git a/streampark-flink/streampark-flink-core/pom.xml b/streampark-flink/streampark-flink-core/pom.xml
index 6302b109ea..6f0254eed3 100644
--- a/streampark-flink/streampark-flink-core/pom.xml
+++ b/streampark-flink/streampark-flink-core/pom.xml
@@ -20,7 +20,7 @@
     <parent>
         <groupId>org.apache.streampark</groupId>
         <artifactId>streampark-flink</artifactId>
-        <version>2.1.5</version>
+        <version>2.1.6</version>
     </parent>
 
     <artifactId>streampark-flink-core_${scala.binary.version}</artifactId>
diff --git a/streampark-flink/streampark-flink-kubernetes/pom.xml b/streampark-flink/streampark-flink-kubernetes/pom.xml
index bc5e1b46dc..39b2c94e4f 100644
--- a/streampark-flink/streampark-flink-kubernetes/pom.xml
+++ b/streampark-flink/streampark-flink-kubernetes/pom.xml
@@ -21,7 +21,7 @@
     <parent>
         <groupId>org.apache.streampark</groupId>
         <artifactId>streampark-flink</artifactId>
-        <version>2.1.5</version>
+        <version>2.1.6</version>
     </parent>
 
     <artifactId>streampark-flink-kubernetes_${scala.binary.version}</artifactId>
diff --git a/streampark-flink/streampark-flink-packer/pom.xml b/streampark-flink/streampark-flink-packer/pom.xml
index f2cfd30799..f4d6150c0d 100644
--- a/streampark-flink/streampark-flink-packer/pom.xml
+++ b/streampark-flink/streampark-flink-packer/pom.xml
@@ -20,7 +20,7 @@
     <parent>
         <groupId>org.apache.streampark</groupId>
         <artifactId>streampark-flink</artifactId>
-        <version>2.1.5</version>
+        <version>2.1.6</version>
     </parent>
 
     <artifactId>streampark-flink-packer_${scala.binary.version}</artifactId>
diff --git a/streampark-flink/streampark-flink-proxy/pom.xml b/streampark-flink/streampark-flink-proxy/pom.xml
index 63cb69ea94..4a02303386 100644
--- a/streampark-flink/streampark-flink-proxy/pom.xml
+++ b/streampark-flink/streampark-flink-proxy/pom.xml
@@ -20,7 +20,7 @@
     <parent>
         <groupId>org.apache.streampark</groupId>
         <artifactId>streampark-flink</artifactId>
-        <version>2.1.5</version>
+        <version>2.1.6</version>
     </parent>
 
     <artifactId>streampark-flink-proxy_${scala.binary.version}</artifactId>
diff --git a/streampark-flink/streampark-flink-shims/pom.xml b/streampark-flink/streampark-flink-shims/pom.xml
index 6b5de3a623..82a8f94ab3 100644
--- a/streampark-flink/streampark-flink-shims/pom.xml
+++ b/streampark-flink/streampark-flink-shims/pom.xml
@@ -21,7 +21,7 @@
     <parent>
         <groupId>org.apache.streampark</groupId>
         <artifactId>streampark-flink</artifactId>
-        <version>2.1.5</version>
+        <version>2.1.6</version>
     </parent>
 
     <artifactId>streampark-flink-shims</artifactId>
diff --git a/streampark-flink/streampark-flink-shims/streampark-flink-shims-base/pom.xml b/streampark-flink/streampark-flink-shims/streampark-flink-shims-base/pom.xml
index b1374b2b7c..3dcb3edd17 100644
--- a/streampark-flink/streampark-flink-shims/streampark-flink-shims-base/pom.xml
+++ b/streampark-flink/streampark-flink-shims/streampark-flink-shims-base/pom.xml
@@ -22,7 +22,7 @@
     <parent>
         <groupId>org.apache.streampark</groupId>
         <artifactId>streampark-flink-shims</artifactId>
-        <version>2.1.5</version>
+        <version>2.1.6</version>
     </parent>
 
     <artifactId>streampark-flink-shims-base_${scala.binary.version}</artifactId>
diff --git a/streampark-flink/streampark-flink-shims/streampark-flink-shims-test/pom.xml b/streampark-flink/streampark-flink-shims/streampark-flink-shims-test/pom.xml
index c9771bcb97..0cd5384168 100644
--- a/streampark-flink/streampark-flink-shims/streampark-flink-shims-test/pom.xml
+++ b/streampark-flink/streampark-flink-shims/streampark-flink-shims-test/pom.xml
@@ -23,7 +23,7 @@
     <parent>
         <groupId>org.apache.streampark</groupId>
         <artifactId>streampark-flink-shims</artifactId>
-        <version>2.1.5</version>
+        <version>2.1.6</version>
     </parent>
 
     <artifactId>streampark-flink-shims-test_${scala.binary.version}</artifactId>
diff --git a/streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.12/pom.xml b/streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.12/pom.xml
index 4fd5a6e638..d686daa51b 100644
--- a/streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.12/pom.xml
+++ b/streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.12/pom.xml
@@ -22,7 +22,7 @@
     <parent>
         <groupId>org.apache.streampark</groupId>
         <artifactId>streampark-flink-shims</artifactId>
-        <version>2.1.5</version>
+        <version>2.1.6</version>
     </parent>
 
     <artifactId>streampark-flink-shims_flink-1.12_${scala.binary.version}</artifactId>
diff --git a/streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.13/pom.xml b/streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.13/pom.xml
index 36e27751ea..996400c83a 100644
--- a/streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.13/pom.xml
+++ b/streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.13/pom.xml
@@ -21,7 +21,7 @@
     <parent>
         <groupId>org.apache.streampark</groupId>
         <artifactId>streampark-flink-shims</artifactId>
-        <version>2.1.5</version>
+        <version>2.1.6</version>
     </parent>
 
     <artifactId>streampark-flink-shims_flink-1.13_${scala.binary.version}</artifactId>
diff --git a/streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.14/pom.xml b/streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.14/pom.xml
index dd902877d2..6c5cc99536 100644
--- a/streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.14/pom.xml
+++ b/streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.14/pom.xml
@@ -21,7 +21,7 @@
     <parent>
         <groupId>org.apache.streampark</groupId>
         <artifactId>streampark-flink-shims</artifactId>
-        <version>2.1.5</version>
+        <version>2.1.6</version>
     </parent>
 
     <artifactId>streampark-flink-shims_flink-1.14_${scala.binary.version}</artifactId>
diff --git a/streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.15/pom.xml b/streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.15/pom.xml
index 311a47c38d..836d06b6b7 100644
--- a/streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.15/pom.xml
+++ b/streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.15/pom.xml
@@ -23,7 +23,7 @@
     <parent>
         <groupId>org.apache.streampark</groupId>
         <artifactId>streampark-flink-shims</artifactId>
-        <version>2.1.5</version>
+        <version>2.1.6</version>
     </parent>
 
     <artifactId>streampark-flink-shims_flink-1.15_${scala.binary.version}</artifactId>
diff --git a/streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.16/pom.xml b/streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.16/pom.xml
index 8b546e2527..48001a6d58 100644
--- a/streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.16/pom.xml
+++ b/streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.16/pom.xml
@@ -22,7 +22,7 @@
     <parent>
         <groupId>org.apache.streampark</groupId>
         <artifactId>streampark-flink-shims</artifactId>
-        <version>2.1.5</version>
+        <version>2.1.6</version>
     </parent>
 
     <artifactId>streampark-flink-shims_flink-1.16_${scala.binary.version}</artifactId>
diff --git a/streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.17/pom.xml b/streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.17/pom.xml
index b71d0745d9..361490c6d0 100644
--- a/streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.17/pom.xml
+++ b/streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.17/pom.xml
@@ -22,7 +22,7 @@
     <parent>
         <groupId>org.apache.streampark</groupId>
         <artifactId>streampark-flink-shims</artifactId>
-        <version>2.1.5</version>
+        <version>2.1.6</version>
     </parent>
 
     <artifactId>streampark-flink-shims_flink-1.17_${scala.binary.version}</artifactId>
diff --git a/streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.18/pom.xml b/streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.18/pom.xml
index dc201145d1..ce7e7251e0 100644
--- a/streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.18/pom.xml
+++ b/streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.18/pom.xml
@@ -22,7 +22,7 @@
     <parent>
         <groupId>org.apache.streampark</groupId>
         <artifactId>streampark-flink-shims</artifactId>
-        <version>2.1.5</version>
+        <version>2.1.6</version>
     </parent>
 
     <artifactId>streampark-flink-shims_flink-1.18_${scala.binary.version}</artifactId>
diff --git a/streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.19/pom.xml b/streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.19/pom.xml
index 9af7e0cd09..e43b15e1da 100644
--- a/streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.19/pom.xml
+++ b/streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.19/pom.xml
@@ -22,7 +22,7 @@
     <parent>
         <groupId>org.apache.streampark</groupId>
         <artifactId>streampark-flink-shims</artifactId>
-        <version>2.1.5</version>
+        <version>2.1.6</version>
     </parent>
 
     <artifactId>streampark-flink-shims_flink-1.19_${scala.binary.version}</artifactId>
diff --git a/streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.20/pom.xml b/streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.20/pom.xml
index f296512342..76f3aa0dfe 100644
--- a/streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.20/pom.xml
+++ b/streampark-flink/streampark-flink-shims/streampark-flink-shims_flink-1.20/pom.xml
@@ -22,7 +22,7 @@
     <parent>
         <groupId>org.apache.streampark</groupId>
         <artifactId>streampark-flink-shims</artifactId>
-        <version>2.1.5</version>
+        <version>2.1.6</version>
     </parent>
 
     <artifactId>streampark-flink-shims_flink-1.20_${scala.binary.version}</artifactId>
diff --git a/streampark-flink/streampark-flink-sqlclient/pom.xml b/streampark-flink/streampark-flink-sqlclient/pom.xml
index 0d05c4ee59..3c1b56cf88 100644
--- a/streampark-flink/streampark-flink-sqlclient/pom.xml
+++ b/streampark-flink/streampark-flink-sqlclient/pom.xml
@@ -20,7 +20,7 @@
     <parent>
         <groupId>org.apache.streampark</groupId>
         <artifactId>streampark-flink</artifactId>
-        <version>2.1.5</version>
+        <version>2.1.6</version>
     </parent>
 
     <artifactId>streampark-flink-sqlclient_${scala.binary.version}</artifactId>
diff --git a/streampark-flink/streampark-flink-udf/pom.xml b/streampark-flink/streampark-flink-udf/pom.xml
index 2d6efd2644..ed0b9cd5d6 100644
--- a/streampark-flink/streampark-flink-udf/pom.xml
+++ b/streampark-flink/streampark-flink-udf/pom.xml
@@ -20,7 +20,7 @@
     <parent>
         <groupId>org.apache.streampark</groupId>
         <artifactId>streampark-flink</artifactId>
-        <version>2.1.5</version>
+        <version>2.1.6</version>
     </parent>
 
     <artifactId>streampark-flink-udf_${scala.binary.version}</artifactId>
diff --git a/streampark-shaded/pom.xml b/streampark-shaded/pom.xml
index 8888f7204f..b197a4fd1e 100644
--- a/streampark-shaded/pom.xml
+++ b/streampark-shaded/pom.xml
@@ -21,7 +21,7 @@
     <parent>
         <groupId>org.apache.streampark</groupId>
         <artifactId>streampark</artifactId>
-        <version>2.1.5</version>
+        <version>2.1.6</version>
     </parent>
 
     <artifactId>streampark-shaded</artifactId>
diff --git a/streampark-spark/pom.xml b/streampark-spark/pom.xml
index bc859850d4..715cbc1d2b 100644
--- a/streampark-spark/pom.xml
+++ b/streampark-spark/pom.xml
@@ -20,7 +20,7 @@
     <parent>
         <groupId>org.apache.streampark</groupId>
         <artifactId>streampark</artifactId>
-        <version>2.1.5</version>
+        <version>2.1.6</version>
     </parent>
 
     <artifactId>streampark-spark</artifactId>
diff --git a/streampark-spark/streampark-spark-cli/pom.xml b/streampark-spark/streampark-spark-cli/pom.xml
index 0f96654356..dfb5fb12fe 100644
--- a/streampark-spark/streampark-spark-cli/pom.xml
+++ b/streampark-spark/streampark-spark-cli/pom.xml
@@ -20,7 +20,7 @@
     <parent>
         <groupId>org.apache.streampark</groupId>
         <artifactId>streampark-spark</artifactId>
-        <version>2.1.5</version>
+        <version>2.1.6</version>
     </parent>
 
     <artifactId>streampark-spark-cli</artifactId>
diff --git a/streampark-spark/streampark-spark-connector/pom.xml b/streampark-spark/streampark-spark-connector/pom.xml
index 7f48e51fe8..2e0ba2e4d2 100644
--- a/streampark-spark/streampark-spark-connector/pom.xml
+++ b/streampark-spark/streampark-spark-connector/pom.xml
@@ -21,7 +21,7 @@
     <parent>
         <groupId>org.apache.streampark</groupId>
         <artifactId>streampark-spark</artifactId>
-        <version>2.1.5</version>
+        <version>2.1.6</version>
     </parent>
 
     <artifactId>streampark-spark-connector_2.12</artifactId>
diff --git a/streampark-spark/streampark-spark-connector/streampark-spark-connector-base/pom.xml b/streampark-spark/streampark-spark-connector/streampark-spark-connector-base/pom.xml
index 8888089e08..6c666a6892 100644
--- a/streampark-spark/streampark-spark-connector/streampark-spark-connector-base/pom.xml
+++ b/streampark-spark/streampark-spark-connector/streampark-spark-connector-base/pom.xml
@@ -22,7 +22,7 @@
     <parent>
         <groupId>org.apache.streampark</groupId>
         <artifactId>streampark-spark-connector_2.12</artifactId>
-        <version>2.1.5</version>
+        <version>2.1.6</version>
     </parent>
 
     <artifactId>streampark-spark-connector-base_2.12</artifactId>
diff --git a/streampark-spark/streampark-spark-connector/streampark-spark-connector-kafka/pom.xml b/streampark-spark/streampark-spark-connector/streampark-spark-connector-kafka/pom.xml
index c4d568bff1..ff687408dd 100644
--- a/streampark-spark/streampark-spark-connector/streampark-spark-connector-kafka/pom.xml
+++ b/streampark-spark/streampark-spark-connector/streampark-spark-connector-kafka/pom.xml
@@ -21,7 +21,7 @@
     <parent>
         <groupId>org.apache.streampark</groupId>
         <artifactId>streampark-spark-connector_2.12</artifactId>
-        <version>2.1.5</version>
+        <version>2.1.6</version>
     </parent>
 
     <artifactId>streampark-spark-connector-kafka_2.12</artifactId>
diff --git a/streampark-spark/streampark-spark-core/pom.xml b/streampark-spark/streampark-spark-core/pom.xml
index a881d971da..f2fde645d2 100644
--- a/streampark-spark/streampark-spark-core/pom.xml
+++ b/streampark-spark/streampark-spark-core/pom.xml
@@ -20,7 +20,7 @@
     <parent>
         <groupId>org.apache.streampark</groupId>
         <artifactId>streampark-spark</artifactId>
-        <version>2.1.5</version>
+        <version>2.1.6</version>
     </parent>
 
     <artifactId>streampark-spark-core_2.12</artifactId>