This is an automated email from the ASF dual-hosted git repository.

benjobs pushed a commit to branch dev-2.1.3
in repository https://gitbox.apache.org/repos/asf/incubator-streampark.git


The following commit(s) were added to refs/heads/dev-2.1.3 by this push:
     new 834185c7d [Improve] iter minor improvement
834185c7d is described below

commit 834185c7d545af383bf808a9993bef92b97a45a9
Author: benjobs <[email protected]>
AuthorDate: Sun Dec 31 18:11:18 2023 +0800

    [Improve] iter minor improvement
---
 .../java/org/apache/streampark/console/core/entity/Project.java    | 7 +++----
 1 file changed, 3 insertions(+), 4 deletions(-)

diff --git 
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/Project.java
 
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/Project.java
index ebf023d08..b44035824 100644
--- 
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/Project.java
+++ 
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/entity/Project.java
@@ -265,14 +265,13 @@ public class Project implements Serializable {
 
     String result = null;
     Iterator<String> dangerIter = Arrays.asList(";", "|", "&", "||", 
"&&").iterator();
-    Iterator<String> argsIter = Arrays.stream(param.split("\\s+")).iterator();
-
+    String[] argsList = param.split("\\s+");
     while (result == null && dangerIter.hasNext()) {
       String danger = dangerIter.next();
-      while (result == null && argsIter.hasNext()) {
-        String arg = argsIter.next();
+      for (String arg : argsList) {
         if (arg.contains(danger)) {
           result = arg;
+          break;
         }
       }
     }

Reply via email to