[ Functions ] Fixed some incorrect usage methods. (#11167)

- Fixed some useless loops. - Fixed incorrect usage of Array tostring method.
apache · Jun 30, 2021 · 7ef489a · 7ef489a
1 parent 8579929
commit 7ef489a
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/...r-config-validation/src/main/java/org/apache/pulsar/config/validation/ValidatorImpls.java b/...r-config-validation/src/main/java/org/apache/pulsar/config/validation/ValidatorImpls.java
@@ -204,7 +204,7 @@ public void validateField(String name, Object o) {
             if (count == 0) {
                 throw new IllegalArgumentException(
                         String.format("Field '%s' with value '%s' does not implement any of these classes %s",
-                                name, o, classesImplements));
+                                name, o, Arrays.toString(classesImplements)));
             }
         }
     }

diff --git a/...tions/worker/src/main/java/org/apache/pulsar/functions/worker/FunctionRuntimeManager.java b/...tions/worker/src/main/java/org/apache/pulsar/functions/worker/FunctionRuntimeManager.java
@@ -944,6 +944,7 @@ private boolean needsStart(Assignment assignment) {
                 for (Function.FunctionState state : functionMetaData.getInstanceStatesMap().values()) {
                     if (state == Function.FunctionState.RUNNING) {
                         toStart = true;
+                        break;
                     }
                 }
             } else {