[pulsar] branch master updated: When restart function, if assigned work does not exist, print warn log. (#16303)

[technoboy]

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

technoboy pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/master by this push:
     new bdbe397fa05 When restart function, if assigned work does not exist, 
print warn log. (#16303)
bdbe397fa05 is described below

commit bdbe397fa058433d06a2a53b9162b9e3e2730e83
Author: Baodi Shi <wudixiaolong...@icloud.com>
AuthorDate: Sun Jul 31 11:46:25 2022 +0800

    When restart function, if assigned work does not exist, print warn log. 
(#16303)
---
 .../org/apache/pulsar/functions/worker/FunctionRuntimeManager.java   | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

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 3b0eaa97a65..006437cee3b 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
@@ -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);