srkukarni commented on a change in pull request #7474:
URL: https://github.com/apache/pulsar/pull/7474#discussion_r451695027
##########
File path:
pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/MembershipManager.java
##########
@@ -225,7 +232,8 @@ public void checkFailures(FunctionMetaDataManager
functionMetaDataManager,
functionRuntimeManager.removeAssignments(needRemove);
}
if (triggerScheduler) {
- log.info("Functions that need scheduling/rescheduling: {}",
needSchedule);
+ log.info("Failure check - Total number of instances that need to
be scheduled/rescheduled: {} | Number of unassigned instances that need to be
scheduled: {} | Number of instances on dead workers that need to be reassigned
{}",
Review comment:
I actually liked the old message. What was the reason for the change?
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
