This is an automated email from the ASF dual-hosted git repository.
benjobs pushed a commit to branch sync_2.1.3
in repository https://gitbox.apache.org/repos/asf/incubator-streampark.git
The following commit(s) were added to refs/heads/sync_2.1.3 by this push:
new ae1670b0c [Improve] check-style issue improvements
ae1670b0c is described below
commit ae1670b0cd647da91dc981c209d5d9ca873aedd6
Author: benjobs <[email protected]>
AuthorDate: Wed Mar 13 18:35:36 2024 +0800
[Improve] check-style issue improvements
---
.../streampark/console/core/service/impl/SavePointServiceImpl.java | 1 -
.../streampark/console/core/service/SavePointServiceTest.java | 3 +--
.../streampark-console-webapp/src/locales/lang/zh-CN/flink/app.ts | 7 +++++++
3 files changed, 8 insertions(+), 3 deletions(-)
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 7fab0fc92..8616e5a21 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
@@ -17,7 +17,6 @@
package org.apache.streampark.console.core.service.impl;
-import org.apache.flink.configuration.CheckpointingOptions;
import org.apache.streampark.common.enums.FlinkExecutionMode;
import org.apache.streampark.common.util.CompletableFutureUtils;
import org.apache.streampark.common.util.ExceptionUtils;
diff --git
a/streampark-console/streampark-console-service/src/test/java/org/apache/streampark/console/core/service/SavePointServiceTest.java
b/streampark-console/streampark-console-service/src/test/java/org/apache/streampark/console/core/service/SavePointServiceTest.java
index 256c95823..e2851c419 100644
---
a/streampark-console/streampark-console-service/src/test/java/org/apache/streampark/console/core/service/SavePointServiceTest.java
+++
b/streampark-console/streampark-console-service/src/test/java/org/apache/streampark/console/core/service/SavePointServiceTest.java
@@ -135,8 +135,7 @@ class SavePointServiceTest extends SpringUnitTestBase {
effective.setAppId(appId);
effective.setTargetType(EffectiveTypeEnum.CONFIG.getType());
effectiveService.save(effective);
- assertThat(savePointServiceImpl.getSavepointFromConfig(app))
- .isEqualTo("hdfs:///test");
+
assertThat(savePointServiceImpl.getSavepointFromConfig(app)).isEqualTo("hdfs:///test");
}
@Test
diff --git
a/streampark-console/streampark-console-webapp/src/locales/lang/zh-CN/flink/app.ts
b/streampark-console/streampark-console-webapp/src/locales/lang/zh-CN/flink/app.ts
index 6ffa0806e..f571b49c1 100644
---
a/streampark-console/streampark-console-webapp/src/locales/lang/zh-CN/flink/app.ts
+++
b/streampark-console/streampark-console-webapp/src/locales/lang/zh-CN/flink/app.ts
@@ -231,6 +231,13 @@ export default {
silent: '静默',
terminated: '终止',
},
+ releaseState: {
+ failed: '发布失败',
+ success: '发布成功',
+ waiting: '待发布',
+ releasing: '发布中',
+ pending: '待回滚',
+ },
addAppTips: {
developmentModePlaceholder: '请选择开发模式',
developmentModeIsRequiredMessage: '开发模式必填',