improve code format

apache · Jan 7, 2024 · 27f13ff · 27f13ff
1 parent 22cbb3f
commit 27f13ff
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 4 deletions.
diff --git a/streampark-common/src/main/java/org/apache/streampark/common/enums/FlinkEnvStatus.java b/streampark-common/src/main/java/org/apache/streampark/common/enums/FlinkEnvStatus.java
@@ -19,10 +19,13 @@
 
 /* the flink environment status */
 public enum FlinkEnvStatus {
+
   /* FLINK_HOME path invalid */
   INVALID("path invalid"),
+
   /* this add/update operation are feasible */
   FEASIBLE("ok"),
+
   /* defined flink name repeated */
   NAME_REPEATED("name repeated"),
 

diff --git a/...ce/src/main/java/org/apache/streampark/console/core/service/impl/FlinkEnvServiceImpl.java b/...ce/src/main/java/org/apache/streampark/console/core/service/impl/FlinkEnvServiceImpl.java
@@ -50,8 +50,6 @@ public class FlinkEnvServiceImpl extends ServiceImpl<FlinkEnvMapper, FlinkEnv>
    * two places will be checked: <br>
    * 1) name repeated <br>
    * 2) flink-dist repeated <br>
-   * -1) invalid path <br>
-   * 0) ok <br>
    */
   @Override
   public String check(FlinkEnv version) {
@@ -74,10 +72,8 @@ public String check(FlinkEnv version) {
         return FlinkEnvStatus.FLINK_DIST_REPEATED.getMsg();
       }
     } else {
-
       return FlinkEnvStatus.INVALID.getMsg();
     }
-
     return FlinkEnvStatus.FEASIBLE.getMsg();
   }