jerrypeng commented on a change in pull request #7474:
URL: https://github.com/apache/pulsar/pull/7474#discussion_r451753300
##
File path:
pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/MembershipManager.java
##
@@ -225,7 +232,8 @@ public void checkFa
jerrypeng commented on a change in pull request #7474:
URL: https://github.com/apache/pulsar/pull/7474#discussion_r451310965
##
File path:
pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/MembershipManager.java
##
@@ -225,7 +232,8 @@ public void checkFa
jerrypeng commented on a change in pull request #7474:
URL: https://github.com/apache/pulsar/pull/7474#discussion_r451308305
##
File path:
pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/SchedulerManager.java
##
@@ -368,8 +390,13 @@ private void invoke
jerrypeng commented on a change in pull request #7474:
URL: https://github.com/apache/pulsar/pull/7474#discussion_r451308599
##
File path:
pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/SchedulerManager.java
##
@@ -526,4 +553,118 @@ static String chec