This is an automated email from the ASF dual-hosted git repository.
muchunjin pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-streampark.git
The following commit(s) were added to refs/heads/dev by this push:
new b26b36ff8 update version to 2.1.0 (#2716)
b26b36ff8 is described below
commit b26b36ff88d1d5e3ca69deb220dbb32d867f636a
Author: benjobs <[email protected]>
AuthorDate: Mon May 1 16:46:59 2023 +0800
update version to 2.1.0 (#2716)
* update version to 2.1.0
* [Improve] FE improvement
* [improve] web.cancel disable
* [Improve] web.cancel disable
---
build.sh | 2 +-
deploy/helm/streampark/Chart.yaml | 4 +-
deploy/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/config/OpenapiConfig.java | 2 +-
.../streampark-console-webapp/package.json | 2 +-
.../flink/app/components/AppDetail/DetailTab.vue | 50 +++++++++++-----------
.../src/views/flink/app/data/detail.data.ts | 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 +-
.../flink/client/trait/FlinkClientTrait.scala | 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-sqlclient/pom.xml | 2 +-
streampark-flink/streampark-flink-udf/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 +-
streampark-storage/pom.xml | 2 +-
55 files changed, 81 insertions(+), 79 deletions(-)
diff --git a/build.sh b/build.sh
index f1937bb81..15afa6a01 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.0-SNAPSHOT %s\n'
$BLUE $RESET
+ printf ' %s Version: 2.1.0 %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/deploy/helm/streampark/Chart.yaml
b/deploy/helm/streampark/Chart.yaml
index f2a697960..f7c52fbcc 100644
--- a/deploy/helm/streampark/Chart.yaml
+++ b/deploy/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.0-SNAPSHOT
-appVersion: 2.1.0-SNAPSHOT
+version: 2.1.0
+appVersion: 2.1.0
diff --git a/deploy/helm/streampark/values.yaml
b/deploy/helm/streampark/values.yaml
index c8be456da..0122e29ce 100644
--- a/deploy/helm/streampark/values.yaml
+++ b/deploy/helm/streampark/values.yaml
@@ -23,7 +23,7 @@ timezone: "Asia/Shanghai"
image:
repository: "apache/streampark"
pullPolicy: "IfNotPresent"
- tag: "2.1.0-SNAPSHOT"
+ tag: "2.1.0"
pullSecret: ""
rbac:
diff --git a/pom.xml b/pom.xml
index 8c9ae5eac..7e1a8409b 100644
--- a/pom.xml
+++ b/pom.xml
@@ -26,7 +26,7 @@
<groupId>org.apache.streampark</groupId>
<artifactId>streampark</artifactId>
- <version>2.1.0-SNAPSHOT</version>
+ <version>2.1.0</version>
<packaging>pom</packaging>
<name>StreamPark Project Parent POM</name>
diff --git a/streampark-common/pom.xml b/streampark-common/pom.xml
index b9a5e646e..bcc174bca 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.0-SNAPSHOT</version>
+ <version>2.1.0</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 ccbe4e8ff..095078e81 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
@@ -201,7 +201,7 @@ object ConfigConst {
println(" ___/ / /_/ / / __/ /_/ / / / / / / /_/ / /_/ / / / ,<
")
println(" /____/\\__/_/ \\___/\\__,_/_/ /_/ /_/ ____/\\__,_/_/
/_/|_| ")
println(" /_/
\n\n")
- println(" Version: 2.1.0-SNAPSHOT
")
+ println(" Version: 2.1.0 ")
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 1eb60dc3b..e782573d5 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.0-SNAPSHOT</version>
+ <version>2.1.0</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 199242020..c2b1181cf 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.0-SNAPSHOT</version>
+ <version>2.1.0</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 251b85bf3..3d29b0cc4 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
@@ -271,7 +271,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.0-SNAPSHOT %s\n'
$BLUE $RESET
+ printf ' %s Version: 2.1.0 %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/config/OpenapiConfig.java
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/config/OpenapiConfig.java
index e076dece2..36a6d2574 100644
---
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/config/OpenapiConfig.java
+++
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/base/config/OpenapiConfig.java
@@ -52,7 +52,7 @@ public class OpenapiConfig implements WebMvcConfigurer {
.name("Apache StreamPark")
.url("https://streampark.apache.org/";)
.email("[email protected]"))
- .version("2.1.0-SNAPSHOT")
+ .version("2.1.0")
.license(new License().name("Apache-2.0 license")))
.components(
new Components()
diff --git a/streampark-console/streampark-console-webapp/package.json
b/streampark-console/streampark-console-webapp/package.json
index 0e83e26b2..349b88971 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.0-SNAPSHOT",
+ "version": "2.1.0",
"author": {
"name": "streampark",
"url": "https://streampark.apache.org";
diff --git
a/streampark-console/streampark-console-webapp/src/views/flink/app/components/AppDetail/DetailTab.vue
b/streampark-console/streampark-console-webapp/src/views/flink/app/components/AppDetail/DetailTab.vue
index 864ca189f..f26c20570 100644
---
a/streampark-console/streampark-console-webapp/src/views/flink/app/components/AppDetail/DetailTab.vue
+++
b/streampark-console/streampark-console-webapp/src/views/flink/app/components/AppDetail/DetailTab.vue
@@ -383,11 +383,11 @@
<TabPane
key="2"
:tab="t('flink.app.detail.detailTab.detailTabName.configuration')"
- v-if="app && app.appType == AppTypeEnum.STREAMPARK_FLINK &&
tabConf.showConf"
+ v-if="app && app.appType === AppTypeEnum.STREAMPARK_FLINK &&
tabConf.showConf"
>
<BasicTable @register="registerConfigTable">
<template #bodyCell="{ column, record }">
- <template v-if="column.dataIndex == 'format'">
+ <template v-if="column.dataIndex === 'format'">
<Tag class="bold-tag" color="#2db7f5" v-if="record.format ===
ConfigTypeEnum.YAML">
yaml
</Tag>
@@ -399,20 +399,20 @@
properties
</Tag>
</template>
- <template v-if="column.dataIndex == 'version'">
+ <template v-if="column.dataIndex === 'version'">
<a-button type="primary" shape="circle" size="small"
class="mr-10px">
{{ record.version }}
</a-button>
</template>
- <template v-if="column.dataIndex == 'effective'">
+ <template v-if="column.dataIndex === 'effective'">
<Tag color="green" v-if="record.effective"> Effective </Tag>
<Tag color="cyan" v-if="record.latest"> Latest </Tag>
</template>
- <template v-if="column.dataIndex == 'createTime'">
+ <template v-if="column.dataIndex === 'createTime'">
<Icon icon="ant-design:clock-circle-outlined" />
{{ record.createTime }}
</template>
- <template v-if="column.dataIndex == 'operation'">
+ <template v-if="column.dataIndex === 'operation'">
<TableAction :actions="getConfAction(record)" />
</template>
</template>
@@ -425,7 +425,7 @@
>
<BasicTable @register="registerFlinkSqlTable">
<template #bodyCell="{ column, record }">
- <template v-if="column.dataIndex == 'candidate'">
+ <template v-if="column.dataIndex === 'candidate'">
<Tag
class="bold-tag"
color="#52c41a"
@@ -448,19 +448,19 @@
History
</Tag>
</template>
- <template v-if="column.dataIndex == 'version'">
+ <template v-if="column.dataIndex === 'version'">
<a-button type="primary" shape="circle" size="small"
class="mr-10px">
{{ record.version }}
</a-button>
</template>
- <template v-if="column.dataIndex == 'effective'">
+ <template v-if="column.dataIndex === 'effective'">
<Tag color="green" v-if="record.effective"> Effective </Tag>
</template>
- <template v-if="column.dataIndex == 'createTime'">
+ <template v-if="column.dataIndex === 'createTime'">
<Icon icon="ant-design:clock-circle-outlined" />
{{ record.createTime }}
</template>
- <template v-if="column.dataIndex == 'operation'">
+ <template v-if="column.dataIndex === 'operation'">
<TableAction :actions="getFlinkSqlAction(record)" />
</template>
</template>
@@ -473,11 +473,11 @@
>
<BasicTable @register="registerSavePointTable">
<template #bodyCell="{ column, record }">
- <template v-if="column.dataIndex == 'triggerTime'">
+ <template v-if="column.dataIndex === 'triggerTime'">
<Icon icon="ant-design:clock-circle-outlined" />
{{ record.triggerTime }}
</template>
- <div v-if="column.dataIndex == 'type'">
+ <div v-if="column.dataIndex === 'type'">
<Tag color="blue" v-if="record['type'] ===
SavePointEnum.CHECK_POINT">
{{ t('flink.app.detail.detailTab.check') }}
</Tag>
@@ -485,10 +485,10 @@
{{ t('flink.app.detail.detailTab.save') }}
</Tag>
</div>
- <div v-if="column.dataIndex == 'latest'">
+ <div v-if="column.dataIndex === 'latest'">
<Tag color="green" v-if="record.latest"> Latest </Tag>
</div>
- <template v-if="column.dataIndex == 'operation'">
+ <template v-if="column.dataIndex === 'operation'">
<TableAction :actions="getSavePointAction(record)" />
</template>
</template>
@@ -501,12 +501,12 @@
>
<BasicTable @register="registerBackupTable">
<template #bodyCell="{ column, record }">
- <template v-if="column.dataIndex == 'version'">
+ <template v-if="column.dataIndex === 'version'">
<a-button type="primary" shape="circle" size="small">
{{ record.version }}
</a-button>
</template>
- <template v-if="column.dataIndex == 'operation'">
+ <template v-if="column.dataIndex === 'operation'">
<TableAction :actions="getBackupAction(record)" />
</template>
</template>
@@ -519,7 +519,7 @@
>
<BasicTable @register="registerLogsTable">
<template #bodyCell="{ column, record }">
- <template v-if="column.dataIndex == 'optionName'">
+ <template v-if="column.dataIndex === 'optionName'">
<Tag color="blue" v-if="record.optionName ===
OperationEnum.RELEASE"> Release </Tag>
<Tag color="green" v-if="record.optionName ===
OperationEnum.START"> Start </Tag>
<Tag color="cyan" v-if="record.optionName ===
OperationEnum.SAVEPOINT">
@@ -527,25 +527,25 @@
</Tag>
<Tag color="orange" v-if="record.optionName ===
OperationEnum.CANCEL"> Cancel </Tag>
</template>
- <template v-if="column.dataIndex == 'yarnAppId'">
- <a-button type="link" @click="handleView(app as any, '')">
+ <template v-if="column.dataIndex === 'yarnAppId'">
+ <a type="link" :href="record.yarnAppId" target="_blank">
{{ record.yarnAppId }}
- </a-button>
+ </a>
</template>
- <template v-if="column.dataIndex == 'jobManagerUrl'">
+ <template v-if="column.dataIndex === 'jobManagerUrl'">
<a type="link" :href="record.jobManagerUrl" target="_blank">
{{ record.jobManagerUrl }}
</a>
</template>
- <template v-if="column.dataIndex == 'optionTime'">
+ <template v-if="column.dataIndex === 'optionTime'">
<Icon icon="ant-design:clock-circle-outlined" />
{{ record.optionTime }}
</template>
- <template v-if="column.dataIndex == 'success'">
+ <template v-if="column.dataIndex === 'success'">
<Tag class="bold-tag" color="#52c41a" v-if="record.success">
SUCCESS </Tag>
<Tag class="bold-tag" color="#f5222d" v-else> FAILED </Tag>
</template>
- <template v-if="column.dataIndex == 'operation'">
+ <template v-if="column.dataIndex === 'operation'">
<TableAction :actions="getOperationLogAction(record)" />
</template>
</template>
diff --git
a/streampark-console/streampark-console-webapp/src/views/flink/app/data/detail.data.ts
b/streampark-console/streampark-console-webapp/src/views/flink/app/data/detail.data.ts
index 4c19b3225..fc5d884c7 100644
---
a/streampark-console/streampark-console-webapp/src/views/flink/app/data/detail.data.ts
+++
b/streampark-console/streampark-console-webapp/src/views/flink/app/data/detail.data.ts
@@ -131,7 +131,7 @@ export const getBackupColumns = (): BasicColumn[] => [
];
export const getOptionLogColumns = (): BasicColumn[] => [
- { title: 'Operation Name', dataIndex: 'optionName' },
+ { title: 'Operation Name', dataIndex: 'optionName', width: 150 },
{ title: 'Application Id', dataIndex: 'yarnAppId' },
{ title: 'JobManager URL', dataIndex: 'jobManagerUrl' },
{ title: 'Start Status', dataIndex: 'success', width: 120 },
diff --git a/streampark-flink/pom.xml b/streampark-flink/pom.xml
index 33d75d9a6..1ac2d2142 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.0-SNAPSHOT</version>
+ <version>2.1.0</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 a0ceaedf6..b8a9efc7e 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.0-SNAPSHOT</version>
+ <version>2.1.0</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 27b15c455..7c4ba3641 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.0-SNAPSHOT</version>
+ <version>2.1.0</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 9cf7c8617..77a9c6094 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.0-SNAPSHOT</version>
+ <version>2.1.0</version>
</parent>
<artifactId>streampark-flink-client-core_${scala.binary.version}</artifactId>
diff --git
a/streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/trait/FlinkClientTrait.scala
b/streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/trait/FlinkClientTrait.scala
index 325bc9ff3..dca2863cc 100644
---
a/streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/trait/FlinkClientTrait.scala
+++
b/streampark-flink/streampark-flink-client/streampark-flink-client-core/src/main/scala/org/apache/streampark/flink/client/trait/FlinkClientTrait.scala
@@ -40,6 +40,7 @@ import org.apache.flink.util.FlinkException
import org.apache.flink.util.Preconditions.checkNotNull
import java.io.File
+import java.lang.{Boolean => JavaBool}
import java.util.{Collections, List => JavaList, Map => JavaMap}
import scala.annotation.tailrec
@@ -98,6 +99,7 @@ trait FlinkClientTrait extends Logger {
.safeSet(ApplicationConfiguration.APPLICATION_MAIN_CLASS,
submitRequest.appMain)
.safeSet(ApplicationConfiguration.APPLICATION_ARGS,
extractProgramArgs(submitRequest))
.safeSet(PipelineOptionsInternal.PIPELINE_FIXED_JOB_ID,
submitRequest.jobId)
+ .safeSet(WebOptions.CANCEL_ENABLE, JavaBool.FALSE)
if (
!submitRequest.properties.containsKey(CheckpointingOptions.MAX_RETAINED_CHECKPOINTS.key())
diff --git a/streampark-flink/streampark-flink-connector/pom.xml
b/streampark-flink/streampark-flink-connector/pom.xml
index 27721fc45..246b202c8 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.0-SNAPSHOT</version>
+ <version>2.1.0</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 7507e4001..b80a73985 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.0-SNAPSHOT</version>
+ <version>2.1.0</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 c0696b8a8..e5b3e2ac1 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.0-SNAPSHOT</version>
+ <version>2.1.0</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 1169cb4ce..05baf05db 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.0-SNAPSHOT</version>
+ <version>2.1.0</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 d5fdfdd92..d3a133198 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.0-SNAPSHOT</version>
+ <version>2.1.0</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 0f89e42f9..349548fd0 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.0-SNAPSHOT</version>
+ <version>2.1.0</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 3236dbe56..a9e018f19 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.0-SNAPSHOT</version>
+ <version>2.1.0</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 a3d15ee64..097f177b3 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.0-SNAPSHOT</version>
+ <version>2.1.0</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 3f15f4e20..14e50d106 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.0-SNAPSHOT</version>
+ <version>2.1.0</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 5a9683947..26653c526 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.0-SNAPSHOT</version>
+ <version>2.1.0</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 29d3bd62d..f95076a6d 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.0-SNAPSHOT</version>
+ <version>2.1.0</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 17e53c43e..77733af25 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.0-SNAPSHOT</version>
+ <version>2.1.0</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 d9c36b569..2d21f587a 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.0-SNAPSHOT</version>
+ <version>2.1.0</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 137329369..eff0e0ed5 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.0-SNAPSHOT</version>
+ <version>2.1.0</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 019d85a48..20e789d82 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.0-SNAPSHOT</version>
+ <version>2.1.0</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 13ac2d821..32efcfc3c 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.0-SNAPSHOT</version>
+ <version>2.1.0</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 da594bd1c..9a2ef31a8 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.0-SNAPSHOT</version>
+ <version>2.1.0</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 56d626de5..97ed93547 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.0-SNAPSHOT</version>
+ <version>2.1.0</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 63346dabd..5a6dd9d83 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.0-SNAPSHOT</version>
+ <version>2.1.0</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 41ca70913..685994023 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.0-SNAPSHOT</version>
+ <version>2.1.0</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 776aad238..86d566aad 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.0-SNAPSHOT</version>
+ <version>2.1.0</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 d34d33649..b7167fb48 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.0-SNAPSHOT</version>
+ <version>2.1.0</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 ebca01da6..8c3d29bc3 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.0-SNAPSHOT</version>
+ <version>2.1.0</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 79c8d746a..67e9bce50 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.0-SNAPSHOT</version>
+ <version>2.1.0</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 3e0a0d9f1..f75fc0050 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.0-SNAPSHOT</version>
+ <version>2.1.0</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 5fab3f84d..8cec914d9 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.0-SNAPSHOT</version>
+ <version>2.1.0</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 7ae37cb45..f8f6cecd6 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.0-SNAPSHOT</version>
+ <version>2.1.0</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 357477db2..68286ae99 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.0-SNAPSHOT</version>
+ <version>2.1.0</version>
</parent>
<artifactId>streampark-flink-shims_flink-1.17_${scala.binary.version}</artifactId>
diff --git a/streampark-flink/streampark-flink-sqlclient/pom.xml
b/streampark-flink/streampark-flink-sqlclient/pom.xml
index 3e6c4bd95..58892b026 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.0-SNAPSHOT</version>
+ <version>2.1.0</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 e90b9ef72..afe95fb0e 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.0-SNAPSHOT</version>
+ <version>2.1.0</version>
</parent>
<artifactId>streampark-flink-udf_${scala.binary.version}</artifactId>
diff --git a/streampark-spark/pom.xml b/streampark-spark/pom.xml
index df95c37b6..31ac11780 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.0-SNAPSHOT</version>
+ <version>2.1.0</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 327ca819e..a4c7c9bb2 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.0-SNAPSHOT</version>
+ <version>2.1.0</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 a50327b90..7677f2a66 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.0-SNAPSHOT</version>
+ <version>2.1.0</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 dd1a419bb..4b5a0319e 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.0-SNAPSHOT</version>
+ <version>2.1.0</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 44857b689..8e7161de3 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.0-SNAPSHOT</version>
+ <version>2.1.0</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 9c2210377..c0e6387d8 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.0-SNAPSHOT</version>
+ <version>2.1.0</version>
</parent>
<artifactId>streampark-spark-core_2.12</artifactId>
diff --git a/streampark-storage/pom.xml b/streampark-storage/pom.xml
index d37892662..f06e827c8 100644
--- a/streampark-storage/pom.xml
+++ b/streampark-storage/pom.xml
@@ -22,7 +22,7 @@
<parent>
<groupId>org.apache.streampark</groupId>
<artifactId>streampark</artifactId>
- <version>2.1.0-SNAPSHOT</version>
+ <version>2.1.0</version>
</parent>
<artifactId>streampark-storage</artifactId>
