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: '开发模式必填',

Reply via email to