diff --git a/pulsar-config-validation/src/main/java/org/apache/pulsar/config/validation/ValidatorImpls.java b/pulsar-config-validation/src/main/java/org/apache/pulsar/config/validation/ValidatorImpls.java index 23cb924f17e18..1cf53009b3dfb 100644 --- a/pulsar-config-validation/src/main/java/org/apache/pulsar/config/validation/ValidatorImpls.java +++ b/pulsar-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/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/FunctionRuntimeManager.java b/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/FunctionRuntimeManager.java index e074323bc970f..eaad1320d7ce8 100644 --- a/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/FunctionRuntimeManager.java +++ b/pulsar-functions/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 {