When restart function, if assigned work does not exist, print warn log.
@@ -447,9 +447,8 @@ public class FunctionRuntimeManager implements AutoCloseable {
}
}
if (workerInfo == null) {
- if (log.isDebugEnabled()) {
- log.debug("[{}] has not been assigned yet", fullyQualifiedInstanceId);
- }
+ log.warn("[{}] has not been assigned yet, assignment: [{}], workerList: [{}]",
+ fullyQualifiedInstanceId, assignment, workerInfoList);
continue;
}
restartFunctionUsingPulsarAdmin(assignment, tenant, namespace, functionName, false);
