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 index 58087529bc..2f7ddef196 100644 --- 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/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/FlinkEnvServiceImpl.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/FlinkEnvServiceImpl.java index 9695444d40..2b1ae56a11 100644 --- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/FlinkEnvServiceImpl.java +++ b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/FlinkEnvServiceImpl.java @@ -50,8 +50,6 @@ public class FlinkEnvServiceImpl extends ServiceImpl * two places will be checked:
* 1) name repeated
* 2) flink-dist repeated
- * -1) invalid path
- * 0) ok
*/ @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(); }