[Improve] An exception occurs when the job name contains Spaces

apache · Jan 20, 2025 · 743ac6d · 743ac6d
1 parent 6fa886b
commit 743ac6d
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/...service/src/main/java/org/apache/streampark/console/base/exception/ApiAlertException.java b/...service/src/main/java/org/apache/streampark/console/base/exception/ApiAlertException.java
@@ -79,7 +79,6 @@ public static void throwIfTrue(boolean expression, String errorMsgFmt, Object...
         }
     }
 
-
     /**
      * Validates a given condition and throws an ApiAlertException if the condition is false.
      * This method is used to enforce business rules and ensure the validity of input parameters or states.

diff --git a/...e/streampark/console/core/service/application/impl/FlinkApplicationManageServiceImpl.java b/...e/streampark/console/core/service/application/impl/FlinkApplicationManageServiceImpl.java
@@ -336,9 +336,10 @@ public boolean create(FlinkApplication appParam) {
         appParam.setDefaultModeIngress(settingService.getIngressModeDefault());
         String jobName = appParam.getJobName();
         // validate job application
-        validateCondition(!jobName.contains(" "), "The added job name `%s` is an invalid character and cannot contain Spaces", jobName);
-        validateCondition(validateQueueIfNeeded(appParam), ERROR_APP_QUEUE_HINT, appParam.getYarnQueue(), appParam.getTeamId());
-
+        validateCondition(!jobName.contains(" "),
+            "The added job name `%s` is an invalid character and cannot contain Spaces", jobName);
+        validateCondition(validateQueueIfNeeded(appParam), ERROR_APP_QUEUE_HINT, appParam.getYarnQueue(),
+            appParam.getTeamId());
 
         appParam.doSetHotParams();
         if (appParam.isUploadJob()) {
-Original file line number
+Diff line change
@@ Expand Up @@
             }
         }
         /**
          * Validates a given condition and throws an ApiAlertException if the condition is false.
          * This method is used to enforce business rules and ensure the validity of input parameters or states.
@@ Expand Down @@