This is an automated email from the ASF dual-hosted git repository.
wolfboys pushed a commit to branch dev-2.1.8
in repository https://gitbox.apache.org/repos/asf/streampark.git
The following commit(s) were added to refs/heads/dev-2.1.8 by this push:
new e0893f638 fix(console): validate pagination sort fields (#4350)
e0893f638 is described below
commit e0893f638b9a76553d3a5c989801273e7bb7fe8d
Author: benjobs <[email protected]>
AuthorDate: Wed May 27 16:38:10 2026 +0800
fix(console): validate pagination sort fields (#4350)
* fix(console): validate pagination sort fields
---
NOTICE | 2 +-
build.sh | 2 +-
dist-material/release-docs/NOTICE | 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 +-
streampark-console/pom.xml | 2 +-
.../streampark-console-service/pom.xml | 2 +-
.../src/main/assembly/bin/streampark.sh | 2 +-
.../console/base/mybatis/pager/MybatisPager.java | 8 ++-
.../console/system/runner/StartedUpRunner.java | 2 +-
.../base/mybatis/pager/MybatisPagerTest.java | 65 ++++++++++++++++++++++
.../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-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 +-
.../flink/connector/hbase/source/HBaseSource.scala | 3 +-
.../streampark-flink-connector-http/pom.xml | 2 +-
.../streampark-flink-connector-influx/pom.xml | 2 +-
.../streampark-flink-connector-jdbc/pom.xml | 2 +-
.../flink/connector/jdbc/source/JdbcSource.scala | 3 +-
.../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 +-
63 files changed, 134 insertions(+), 65 deletions(-)
diff --git a/NOTICE b/NOTICE
index 944f63886..621dea7c0 100644
--- a/NOTICE
+++ b/NOTICE
@@ -1,5 +1,5 @@
Apache StreamPark
-Copyright 2022-2025 The Apache Software Foundation
+Copyright 2022-2026 The Apache Software Foundation
This product includes software developed at
The Apache Software Foundation (http://www.apache.org/).
diff --git a/build.sh b/build.sh
index cedca8d41..5074386c6 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.7 %s\n'
$BLUE $RESET
+ printf ' %s Version: 2.1.8 %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/dist-material/release-docs/NOTICE
b/dist-material/release-docs/NOTICE
index 944f63886..621dea7c0 100644
--- a/dist-material/release-docs/NOTICE
+++ b/dist-material/release-docs/NOTICE
@@ -1,5 +1,5 @@
Apache StreamPark
-Copyright 2022-2025 The Apache Software Foundation
+Copyright 2022-2026 The Apache Software Foundation
This product includes software developed at
The Apache Software Foundation (http://www.apache.org/).
diff --git a/docker/README.md b/docker/README.md
index af2530f74..df7a419f1 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.7
+ image: apache/streampark:2.1.8
```
### 2. docker-compose up
diff --git a/docker/docker-compose.yaml b/docker/docker-compose.yaml
index 3fb04a699..fa41e98aa 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.7
+ image: apache/streampark:2.1.8
ports:
- "10000:10000"
environment:
diff --git a/helm/streampark/Chart.yaml b/helm/streampark/Chart.yaml
index 9849b5484..33cb959f2 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.7
-appVersion: 2.1.7
+version: 2.1.8
+appVersion: 2.1.8
diff --git a/helm/streampark/values.yaml b/helm/streampark/values.yaml
index 7a636ced3..801fa8ea6 100644
--- a/helm/streampark/values.yaml
+++ b/helm/streampark/values.yaml
@@ -18,7 +18,7 @@
image:
repository: "apache/streampark"
pullPolicy: "IfNotPresent"
- tag: "2.1.7"
+ tag: "2.1.8"
pullSecret: ""
rbac:
diff --git a/pom.xml b/pom.xml
index 470bccf3d..41e88c2a3 100644
--- a/pom.xml
+++ b/pom.xml
@@ -26,7 +26,7 @@
<groupId>org.apache.streampark</groupId>
<artifactId>streampark</artifactId>
- <version>2.1.7</version>
+ <version>2.1.8</version>
<packaging>pom</packaging>
<name>StreamPark Project Parent POM</name>
diff --git a/streampark-common/pom.xml b/streampark-common/pom.xml
index 620b10187..725595e89 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.7</version>
+ <version>2.1.8</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 5b7874c5b..10b685e5d 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.7 ")
+ println(" Version: 2.1.8 ")
println(" WebSite: https://streampark.apache.org
")
println(" GitHub : https://github.com/apache/streampark
")
println(s" Info : $info ")
diff --git a/streampark-console/pom.xml b/streampark-console/pom.xml
index a9405e14e..e0afa6d11 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.7</version>
+ <version>2.1.8</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 782c7dfe3..821e8e085 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.7</version>
+ <version>2.1.8</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 a5a04cfca..d4b903864 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.7 %s\n'
$BLUE $RESET
+ printf ' %s Version: 2.1.8 %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/base/mybatis/pager/MybatisPager.java
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/mybatis/pager/MybatisPager.java
index b5aa2b2ff..0dcf99a6e 100644
---
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/mybatis/pager/MybatisPager.java
+++
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/mybatis/pager/MybatisPager.java
@@ -28,13 +28,16 @@ import
com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import java.util.ArrayList;
import java.util.List;
+import java.util.regex.Pattern;
@SuppressWarnings("unchecked")
public final class MybatisPager {
+ private static final Pattern SORT_FIELD_PATTERN =
Pattern.compile("^[A-Za-z][A-Za-z0-9_]*$");
+
public static <T> Page<T> getPage(RestRequest request) {
- boolean invalid = request.getSortField().trim().split("\\s+").length > 1;
- if (invalid) {
+ String sortField =
WebUtils.camelToUnderscore(StringUtils.trimToEmpty(request.getSortField()));
+ if (!SORT_FIELD_PATTERN.matcher(sortField).matches()) {
throw new IllegalArgumentException(
String.format("Invalid argument sortField: %s",
request.getSortField()));
}
@@ -48,7 +51,6 @@ public final class MybatisPager {
page.setSize(request.getPageSize());
List<OrderItem> orderItems = new ArrayList<>(2);
- String sortField = WebUtils.camelToUnderscore(request.getSortField());
if (StringUtils.equalsIgnoreCase(request.getSortOrder(),
Constant.ORDER_DESC)) {
orderItems.add(OrderItem.desc(sortField));
} else if (StringUtils.equalsIgnoreCase(request.getSortOrder(),
Constant.ORDER_ASC)) {
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 dd0630071..681c6bc87 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.7
");
+ System.out.println(" Version: 2.1.8
");
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-console/streampark-console-service/src/test/java/org/apache/streampark/console/base/mybatis/pager/MybatisPagerTest.java
b/streampark-console/streampark-console-service/src/test/java/org/apache/streampark/console/base/mybatis/pager/MybatisPagerTest.java
new file mode 100644
index 000000000..31009d706
--- /dev/null
+++
b/streampark-console/streampark-console-service/src/test/java/org/apache/streampark/console/base/mybatis/pager/MybatisPagerTest.java
@@ -0,0 +1,65 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.streampark.console.base.mybatis.pager;
+
+import org.apache.streampark.console.base.domain.RestRequest;
+
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import org.junit.jupiter.api.Test;
+
+import java.util.Arrays;
+
+import static org.assertj.core.api.Assertions.assertThat;
+import static org.assertj.core.api.Assertions.assertThatThrownBy;
+
+class MybatisPagerTest {
+
+ @Test
+ void getPageShouldRejectSqlExpressionSortField() {
+ Arrays.asList(
+ "create_time,CEIL(VARIANT)--",
+ "create_time,SLEEP(10)--",
+ "create_time,PG_SLEEP(10)",
+ "create_time;select 1",
+ "create_time desc",
+ "user.name",
+ "`create_time`",
+ "create_time'--",
+ "create_time/**/desc")
+ .forEach(
+ sortField -> {
+ RestRequest request = new RestRequest();
+ request.setSortField(sortField);
+
+ assertThatThrownBy(() -> MybatisPager.getPage(request))
+ .isInstanceOf(IllegalArgumentException.class)
+ .hasMessageContaining("Invalid argument sortField");
+ });
+ }
+
+ @Test
+ void getPageShouldAcceptColumnNameSortField() {
+ RestRequest request = new RestRequest();
+ request.setSortField("createTime");
+
+ Page<?> page = MybatisPager.getPage(request);
+
+ assertThat(page.orders()).hasSize(1);
+ assertThat(page.orders().get(0).getColumn()).isEqualTo("create_time");
+ }
+}
diff --git a/streampark-console/streampark-console-webapp/package.json
b/streampark-console/streampark-console-webapp/package.json
index 68ee515b5..39320b0eb 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.7",
+ "version": "2.1.8",
"author": {
"name": "streampark",
"url": "https://streampark.apache.org";
diff --git a/streampark-flink/pom.xml b/streampark-flink/pom.xml
index b6dc1100f..99538d66a 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.7</version>
+ <version>2.1.8</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 61f126992..59028598a 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.7</version>
+ <version>2.1.8</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 c6c84ef8f..cfe7a1605 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.7</version>
+ <version>2.1.8</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 6c80e24de..3c86c9af8 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.7</version>
+ <version>2.1.8</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 4e9546c4d..27a54b6be 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.7</version>
+ <version>2.1.8</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 ff507d7d0..7075f648c 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.7</version>
+ <version>2.1.8</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 9e99e303d..4eaa18a78 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.7</version>
+ <version>2.1.8</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 6ee31b611..776c74a9d 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.7</version>
+ <version>2.1.8</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 3b8e88b82..0d2ad1260 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.7</version>
+ <version>2.1.8</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 bdf095f9a..c13042cfc 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.7</version>
+ <version>2.1.8</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 6c9230a36..458ccd447 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.7</version>
+ <version>2.1.8</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 87d06b5fc..b85b2ac98 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.7</version>
+ <version>2.1.8</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 9e7bb0373..e8e4ab7b9 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.7</version>
+ <version>2.1.8</version>
</parent>
<artifactId>streampark-flink-connector-hbase_${scala.binary.version}</artifactId>
diff --git
a/streampark-flink/streampark-flink-connector/streampark-flink-connector-hbase/src/main/scala/org/apache/streampark/flink/connector/hbase/source/HBaseSource.scala
b/streampark-flink/streampark-flink-connector/streampark-flink-connector-hbase/src/main/scala/org/apache/streampark/flink/connector/hbase/source/HBaseSource.scala
index 32f8de5bb..0a04068f7 100644
---
a/streampark-flink/streampark-flink-connector/streampark-flink-connector-hbase/src/main/scala/org/apache/streampark/flink/connector/hbase/source/HBaseSource.scala
+++
b/streampark-flink/streampark-flink-connector/streampark-flink-connector-hbase/src/main/scala/org/apache/streampark/flink/connector/hbase/source/HBaseSource.scala
@@ -29,6 +29,7 @@ import org.apache.hadoop.hbase.client._
import java.util.Properties
import scala.annotation.meta.param
+import scala.collection.JavaConversions._
object HBaseSource {
@@ -61,7 +62,7 @@ class HBaseSource(
}
val jdbc = ConfigUtils.getHBaseConfig(ctx.parameter.toMap)
if (property != null) {
- jdbc.putAll(property)
+ property.foreach(c => jdbc.put(c._1, c._2))
}
val hBaseFunc = new HBaseSourceFunction[R](jdbc, query, func, running)
ctx.addSource(hBaseFunc)
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 be5c9dea1..996070135 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.7</version>
+ <version>2.1.8</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 2555140bd..b96a37bd1 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.7</version>
+ <version>2.1.8</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 54ce6a5b6..72b90a9d2 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.7</version>
+ <version>2.1.8</version>
</parent>
<artifactId>streampark-flink-connector-jdbc_${scala.binary.version}</artifactId>
diff --git
a/streampark-flink/streampark-flink-connector/streampark-flink-connector-jdbc/src/main/scala/org/apache/streampark/flink/connector/jdbc/source/JdbcSource.scala
b/streampark-flink/streampark-flink-connector/streampark-flink-connector-jdbc/src/main/scala/org/apache/streampark/flink/connector/jdbc/source/JdbcSource.scala
index 00e3d6663..8c084aeaa 100644
---
a/streampark-flink/streampark-flink-connector/streampark-flink-connector-jdbc/src/main/scala/org/apache/streampark/flink/connector/jdbc/source/JdbcSource.scala
+++
b/streampark-flink/streampark-flink-connector/streampark-flink-connector-jdbc/src/main/scala/org/apache/streampark/flink/connector/jdbc/source/JdbcSource.scala
@@ -27,6 +27,7 @@ import org.apache.flink.streaming.api.scala.DataStream
import java.util.Properties
import scala.annotation.meta.param
+import scala.collection.JavaConversions._
import scala.collection.Map
object JdbcSource {
@@ -53,7 +54,7 @@ class JdbcSource(
filter: R => Boolean = null): DataStream[R] = {
val jdbc = ConfigUtils.getJdbcProperties(ctx.parameter.toMap, alias)
if (property != null) {
- jdbc.putAll(property)
+ property.foreach(c => jdbc.put(c._1, c._2))
}
val mysqlFun = new JdbcSourceFunction[R](jdbc, sqlFun, func, filter)
ctx.addSource(mysqlFun)
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 f5339e914..b98e397f5 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.7</version>
+ <version>2.1.8</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 ce580d10c..95ec00b03 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.7</version>
+ <version>2.1.8</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 400a5d310..22d84d3fd 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.7</version>
+ <version>2.1.8</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 2226d0d44..c55a21b5b 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.7</version>
+ <version>2.1.8</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 623cd2724..3a8b7883b 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.7</version>
+ <version>2.1.8</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 cccd7b834..7d59a124b 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.7</version>
+ <version>2.1.8</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 a73e1759b..4c22b4252 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.7</version>
+ <version>2.1.8</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 82e5d1ec6..180468f5f 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.7</version>
+ <version>2.1.8</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 51c63d6be..9bbdd1033 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.7</version>
+ <version>2.1.8</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 db352ec73..17bc30875 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.7</version>
+ <version>2.1.8</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 65178f5ba..6221b43e8 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.7</version>
+ <version>2.1.8</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 770c8e3ce..21ba074df 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.7</version>
+ <version>2.1.8</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 1ae06e231..139f98da1 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.7</version>
+ <version>2.1.8</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 70bcbd10a..6aa9daccf 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.7</version>
+ <version>2.1.8</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 4793aad9b..eab99e440 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.7</version>
+ <version>2.1.8</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 3ce181230..93c038a64 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.7</version>
+ <version>2.1.8</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 67662136d..38317a0bc 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.7</version>
+ <version>2.1.8</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 c6b6a0608..16f75ba91 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.7</version>
+ <version>2.1.8</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 a59e9f030..b4eb1ce8a 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.7</version>
+ <version>2.1.8</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 271ceaed2..4cd727c95 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.7</version>
+ <version>2.1.8</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 0ebf481be..b1c099e34 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.7</version>
+ <version>2.1.8</version>
</parent>
<artifactId>streampark-flink-udf_${scala.binary.version}</artifactId>
diff --git a/streampark-shaded/pom.xml b/streampark-shaded/pom.xml
index 69d1f7d02..0aedf3727 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.7</version>
+ <version>2.1.8</version>
</parent>
<artifactId>streampark-shaded</artifactId>
diff --git a/streampark-spark/pom.xml b/streampark-spark/pom.xml
index a5c2faa12..0081b32aa 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.7</version>
+ <version>2.1.8</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 2efcef5d8..e87917a19 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.7</version>
+ <version>2.1.8</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 37b22ca3f..f1606e32a 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.7</version>
+ <version>2.1.8</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 18324426e..95fa2fde6 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.7</version>
+ <version>2.1.8</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 ed70b8b7f..437974092 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.7</version>
+ <version>2.1.8</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 d24547557..3aa93c21b 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.7</version>
+ <version>2.1.8</version>
</parent>
<artifactId>streampark-spark-core_2.12</artifactId>
