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;
}
}
}