This is an automated email from the ASF dual-hosted git repository.
benjobs pushed a commit to branch dev-2.1.7
in repository https://gitbox.apache.org/repos/asf/streampark.git
The following commit(s) were added to refs/heads/dev-2.1.7 by this push:
new 8dd921788 Update version to 2.1.7
8dd921788 is described below
commit 8dd921788dec184c2666fa1c02e805ce6f623252
Author: benjobs <[email protected]>
AuthorDate: Sun Oct 26 23:53:07 2025 +0800
Update version to 2.1.7
---
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 +-
.../streampark/common/conf/ConfigConst.scala | 2 +-
.../apache/streampark/common/util/YarnUtils.scala | 2 +-
streampark-console/pom.xml | 2 +-
.../streampark-console-service/pom.xml | 2 +-
.../src/main/assembly/bin/streampark.sh | 2 +-
.../core/service/impl/ProxyServiceImpl.java | 11 +++++++--
.../core/service/impl/SavepointServiceImpl.java | 26 ++++++++++++++--------
.../console/system/authentication/JWTUtil.java | 12 +++++-----
.../console/system/runner/StartedUpRunner.java | 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-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 +-
.../pom.xml | 2 +-
.../pom.xml | 2 +-
.../pom.xml | 2 +-
.../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-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-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-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 +-
60 files changed, 90 insertions(+), 75 deletions(-)
diff --git a/build.sh b/build.sh
index b0d937769..cedca8d41 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.6 %s\n'
$BLUE $RESET
+ printf ' %s Version: 2.1.7 %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 ce079c4bd..af2530f74 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.6
+ image: apache/streampark:2.1.7
```
### 2. docker-compose up
diff --git a/docker/docker-compose.yaml b/docker/docker-compose.yaml
index 026e9d7d2..3fb04a699 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.6
+ image: apache/streampark:2.1.7
ports:
- "10000:10000"
environment:
diff --git a/helm/streampark/Chart.yaml b/helm/streampark/Chart.yaml
index e2bc774a9..9849b5484 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.6
-appVersion: 2.1.6
+version: 2.1.7
+appVersion: 2.1.7
diff --git a/helm/streampark/values.yaml b/helm/streampark/values.yaml
index a610e43fd..7a636ced3 100644
--- a/helm/streampark/values.yaml
+++ b/helm/streampark/values.yaml
@@ -18,7 +18,7 @@
image:
repository: "apache/streampark"
pullPolicy: "IfNotPresent"
- tag: "2.1.6"
+ tag: "2.1.7"
pullSecret: ""
rbac:
diff --git a/pom.xml b/pom.xml
index 29e5496bf..470bccf3d 100644
--- a/pom.xml
+++ b/pom.xml
@@ -26,7 +26,7 @@
<groupId>org.apache.streampark</groupId>
<artifactId>streampark</artifactId>
- <version>2.1.6</version>
+ <version>2.1.7</version>
<packaging>pom</packaging>
<name>StreamPark Project Parent POM</name>
diff --git a/streampark-common/pom.xml b/streampark-common/pom.xml
index 0dee93ec1..620b10187 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.6</version>
+ <version>2.1.7</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 0b417d0e1..5b7874c5b 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.6 ")
+ println(" Version: 2.1.7 ")
println(" WebSite: https://streampark.apache.org
")
println(" GitHub : https://github.com/apache/streampark
")
println(s" Info : $info ")
diff --git
a/streampark-common/src/main/scala/org/apache/streampark/common/util/YarnUtils.scala
b/streampark-common/src/main/scala/org/apache/streampark/common/util/YarnUtils.scala
index 8edd76558..c2fcd4bfa 100644
---
a/streampark-common/src/main/scala/org/apache/streampark/common/util/YarnUtils.scala
+++
b/streampark-common/src/main/scala/org/apache/streampark/common/util/YarnUtils.scala
@@ -54,7 +54,7 @@ object YarnUtils extends Logger {
"kerberos".equalsIgnoreCase(yarnHttpAuth)
}
- private lazy val hasYarnHttpSimpleAuth: Boolean = {
+ lazy val hasYarnHttpSimpleAuth: Boolean = {
val yarnHttpAuth: String =
InternalConfigHolder.get[String](CommonConfig.STREAMPARK_YARN_AUTH)
"simple".equalsIgnoreCase(yarnHttpAuth)
}
diff --git a/streampark-console/pom.xml b/streampark-console/pom.xml
index 6840e1f9e..a9405e14e 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.6</version>
+ <version>2.1.7</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 d41d96552..782c7dfe3 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.6</version>
+ <version>2.1.7</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 ef575b5df..a5a04cfca 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.6 %s\n'
$BLUE $RESET
+ printf ' %s Version: 2.1.7 %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/core/service/impl/ProxyServiceImpl.java
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ProxyServiceImpl.java
index 5268bb80c..24aba76ef 100644
---
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ProxyServiceImpl.java
+++
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ProxyServiceImpl.java
@@ -17,6 +17,7 @@
package org.apache.streampark.console.core.service.impl;
+import org.apache.streampark.common.util.HadoopConfigUtils;
import org.apache.streampark.common.util.HadoopUtils;
import org.apache.streampark.common.util.YarnUtils;
import org.apache.streampark.console.base.exception.PermissionDeniedException;
@@ -251,9 +252,15 @@ public class ProxyServiceImpl implements ProxyService {
setRestTemplateCredentials(ugi.getShortUserName());
return ugi.doAs(
(PrivilegedExceptionAction<ResponseEntity<?>>) () -> proxy(request,
url, requestEntity));
- } else {
- return proxyRequest(request, url);
}
+
+ if (YarnUtils.hasYarnHttpSimpleAuth()) {
+ String urlTemplate =
+ StringUtils.isNotBlank(request.getQueryString()) ? "%s&user.name=%s"
: "%s?user.name=%s";
+ return proxyRequest(
+ request, String.format(urlTemplate, url,
HadoopConfigUtils.hadoopUserName()));
+ }
+ return proxyRequest(request, url);
}
private ResponseEntity<?> proxy(
diff --git
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/SavepointServiceImpl.java
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/SavepointServiceImpl.java
index befeda433..9c795dcab 100644
---
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/SavepointServiceImpl.java
+++
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/SavepointServiceImpl.java
@@ -23,7 +23,6 @@ import org.apache.streampark.common.util.AssertUtils;
import org.apache.streampark.common.util.CompletableFutureUtils;
import org.apache.streampark.common.util.PropertiesUtils;
import org.apache.streampark.common.util.ThreadUtils;
-import org.apache.streampark.common.util.Utils;
import org.apache.streampark.console.base.domain.RestRequest;
import org.apache.streampark.console.base.exception.InternalException;
import org.apache.streampark.console.base.mybatis.pager.MybatisPager;
@@ -53,6 +52,7 @@ import org.apache.streampark.flink.util.FlinkUtils;
import org.apache.commons.lang3.StringUtils;
import org.apache.flink.configuration.CheckpointingOptions;
import org.apache.flink.configuration.RestOptions;
+import org.apache.flink.util.ExceptionUtils;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
@@ -383,6 +383,7 @@ public class SavepointServiceImpl extends
ServiceImpl<SavepointMapper, Savepoint
Application application,
ApplicationLog applicationLog,
CompletableFuture<SavepointResponse> savepointFuture) {
+ final Date triggerTime = new Date();
CompletableFutureUtils.runTimeout(
savepointFuture,
10L,
@@ -391,12 +392,22 @@ public class SavepointServiceImpl extends
ServiceImpl<SavepointMapper, Savepoint
if (savepointResponse != null &&
savepointResponse.savepointDir() != null) {
applicationLog.setSuccess(true);
String savepointDir = savepointResponse.savepointDir();
+
+ // savepoint successfully add saved
+ Savepoint savepoint = new Savepoint();
+ savepoint.setAppId(application.getId());
+ savepoint.setLatest(true);
+ savepoint.setType(CheckPointType.SAVEPOINT.get());
+ savepoint.setPath(savepointDir);
+ savepoint.setTriggerTime(triggerTime);
+ savepoint.setCreateTime(new Date());
+ save(savepoint);
log.info("Request savepoint successful, savepointDir: {}",
savepointDir);
}
},
e -> {
log.error("Trigger savepoint for flink job failed.", e);
- String exception = Utils.stringifyException(e);
+ String exception = ExceptionUtils.stringifyException(e);
applicationLog.setException(exception);
if (!(e instanceof TimeoutException)) {
applicationLog.setSuccess(false);
@@ -405,13 +416,10 @@ public class SavepointServiceImpl extends
ServiceImpl<SavepointMapper, Savepoint
.whenComplete(
(t, e) -> {
applicationLogService.save(applicationLog);
- if (!application.isKubernetesModeJob()) {
- application.setOptionState(OptionState.NONE.getValue());
- application.setOptionTime(new Date());
- applicationService.update(application);
- flinkAppHttpWatcher.cleanSavepoint(application);
- flinkAppHttpWatcher.initialize();
- }
+ application.setOptionState(OptionState.NONE.getValue());
+ application.setOptionTime(new Date());
+ applicationService.update(application);
+ flinkAppHttpWatcher.initialize();
});
}
diff --git
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/authentication/JWTUtil.java
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/authentication/JWTUtil.java
index 6fadaa228..3abc01679 100644
---
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/authentication/JWTUtil.java
+++
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/system/authentication/JWTUtil.java
@@ -51,7 +51,7 @@ public class JWTUtil {
private static final String JWT_TYPE = "type";
private static final String JWT_TIMESTAMP = "timestamp";
- private static byte[] JWT_KEY = JWTSecret.getJWTSecret(); // Used for HMAC256
+ private static byte[] jetKey = JWTSecret.getJWTSecret(); // Used for HMAC256
/** get username from token */
public static String getUserName(String token) {
@@ -108,7 +108,7 @@ public class JWTUtil {
public static String sign(User user, AuthenticationType authType, Long
expireTime)
throws Exception {
Date date = new Date(expireTime);
- Algorithm algorithm = Algorithm.HMAC256(JWT_KEY);
+ Algorithm algorithm = Algorithm.HMAC256(jetKey);
JWTCreator.Builder builder =
JWT.create()
@@ -153,7 +153,7 @@ public class JWTUtil {
private static DecodedJWT decode(String token) {
try {
- Algorithm algorithm = Algorithm.HMAC256(JWT_KEY);
+ Algorithm algorithm = Algorithm.HMAC256(jetKey);
JWTVerifier verifier = JWT.require(algorithm).build();
return verifier.verify(token);
} catch (Exception e) {
@@ -164,7 +164,7 @@ public class JWTUtil {
public static boolean verify(String token) {
try {
// Decode the signing key using Base64
- Algorithm algorithm = Algorithm.HMAC256(JWT_KEY);
+ Algorithm algorithm = Algorithm.HMAC256(jetKey);
JWTVerifier verifier = JWT.require(algorithm).build();
verifier.verify(token);
return true;
@@ -188,7 +188,7 @@ public class JWTUtil {
byte[] iv = new byte[GCM_IV_LENGTH];
SecureRandom.getInstanceStrong().nextBytes(iv);
- SecretKeySpec keySpec = new SecretKeySpec(JWT_KEY, "AES");
+ SecretKeySpec keySpec = new SecretKeySpec(jetKey, "AES");
// Initialize the cipher
Cipher cipher = Cipher.getInstance(ALGORITHM);
@@ -214,7 +214,7 @@ public class JWTUtil {
byte[] encrypted = new byte[buffer.remaining()];
buffer.get(encrypted);
- SecretKeySpec keySpec = new SecretKeySpec(JWT_KEY, "AES");
+ SecretKeySpec keySpec = new SecretKeySpec(jetKey, "AES");
Cipher cipher = Cipher.getInstance(ALGORITHM);
GCMParameterSpec spec = new GCMParameterSpec(GCM_TAG_LENGTH, iv);
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 05f35766a..dd0630071 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 class StartedUpRunner implements ApplicationRunner {
System.out.println(" ___/ / /_/ / / __/ /_/ / / / / / / /_/ / /_/
/ / / ,< ");
System.out.println(" /____/\\__/_/ \\___/\\__,_/_/ /_/ /_/
____/\\__,_/_/ /_/|_| ");
System.out.println(" /_/
\n\n");
- System.out.println(" Version: 2.1.6
");
+ System.out.println(" Version: 2.1.7
");
System.out.println(" WebSite: https://streampark.apache.org
");
System.out.println(" GitHub : https://github.com/apache/streampark
");
System.out.println(" Info : streampark-console start successful
");
diff --git a/streampark-flink/pom.xml b/streampark-flink/pom.xml
index fb00fe5db..b6dc1100f 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.6</version>
+ <version>2.1.7</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 1202565bd..61f126992 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.6</version>
+ <version>2.1.7</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 afb98c680..c6c84ef8f 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.6</version>
+ <version>2.1.7</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 0a40d9a7e..6c80e24de 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.6</version>
+ <version>2.1.7</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 a11921c3d..4e9546c4d 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.6</version>
+ <version>2.1.7</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 4736d0517..ff507d7d0 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.6</version>
+ <version>2.1.7</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 95f02c267..9e99e303d 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.6</version>
+ <version>2.1.7</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 fe520ed3c..6ee31b611 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.6</version>
+ <version>2.1.7</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 caaefd7a2..3b8e88b82 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.6</version>
+ <version>2.1.7</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 529b7ca2e..bdf095f9a 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.6</version>
+ <version>2.1.7</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 d6edc8ebd..6c9230a36 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.6</version>
+ <version>2.1.7</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 86482e84f..87d06b5fc 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.6</version>
+ <version>2.1.7</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 828f7e80d..9e7bb0373 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.6</version>
+ <version>2.1.7</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 3e511f41e..be5c9dea1 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.6</version>
+ <version>2.1.7</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 5685df821..2555140bd 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.6</version>
+ <version>2.1.7</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 10858dddf..54ce6a5b6 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.6</version>
+ <version>2.1.7</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 edc32dccf..f5339e914 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.6</version>
+ <version>2.1.7</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 449f70414..ce580d10c 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.6</version>
+ <version>2.1.7</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 0606193e1..400a5d310 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.6</version>
+ <version>2.1.7</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 6f0254eed..2226d0d44 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.6</version>
+ <version>2.1.7</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 39b2c94e4..623cd2724 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.6</version>
+ <version>2.1.7</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 f4d6150c0..cccd7b834 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.6</version>
+ <version>2.1.7</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 4a0230338..a73e1759b 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.6</version>
+ <version>2.1.7</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 82a8f94ab..82e5d1ec6 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.6</version>
+ <version>2.1.7</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 3dcb3edd1..51c63d6be 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.6</version>
+ <version>2.1.7</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 0cd538416..db352ec73 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.6</version>
+ <version>2.1.7</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 d686daa51..65178f5ba 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.6</version>
+ <version>2.1.7</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 996400c83..770c8e3ce 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.6</version>
+ <version>2.1.7</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 6c5cc9953..1ae06e231 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.6</version>
+ <version>2.1.7</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 836d06b6b..70bcbd10a 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.6</version>
+ <version>2.1.7</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 48001a6d5..4793aad9b 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.6</version>
+ <version>2.1.7</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 361490c6d..3ce181230 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.6</version>
+ <version>2.1.7</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 ce7e7251e..67662136d 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.6</version>
+ <version>2.1.7</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 e43b15e1d..c6b6a0608 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.6</version>
+ <version>2.1.7</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 76f3aa0df..a59e9f030 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.6</version>
+ <version>2.1.7</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 3c1b56cf8..271ceaed2 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.6</version>
+ <version>2.1.7</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 ed0b9cd5d..0ebf481be 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.6</version>
+ <version>2.1.7</version>
</parent>
<artifactId>streampark-flink-udf_${scala.binary.version}</artifactId>
diff --git a/streampark-shaded/pom.xml b/streampark-shaded/pom.xml
index b197a4fd1..69d1f7d02 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.6</version>
+ <version>2.1.7</version>
</parent>
<artifactId>streampark-shaded</artifactId>
diff --git a/streampark-spark/pom.xml b/streampark-spark/pom.xml
index 715cbc1d2..a5c2faa12 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.6</version>
+ <version>2.1.7</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 dfb5fb12f..2efcef5d8 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.6</version>
+ <version>2.1.7</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 2e0ba2e4d..37b22ca3f 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.6</version>
+ <version>2.1.7</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 6c666a689..18324426e 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.6</version>
+ <version>2.1.7</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 ff687408d..ed70b8b7f 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.6</version>
+ <version>2.1.7</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 f2fde645d..d24547557 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.6</version>
+ <version>2.1.7</version>
</parent>
<artifactId>streampark-spark-core_2.12</artifactId>
