[GitHub] [pulsar] jerrypeng commented on a change in pull request #7474: Log scheduler stats for Pulsar Functions

2020-07-08 Thread GitBox
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

[GitHub] [pulsar] jerrypeng commented on a change in pull request #7474: Log scheduler stats for Pulsar Functions

2020-07-07 Thread GitBox
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

[GitHub] [pulsar] jerrypeng commented on a change in pull request #7474: Log scheduler stats for Pulsar Functions

2020-07-07 Thread GitBox
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

[GitHub] [pulsar] jerrypeng commented on a change in pull request #7474: Log scheduler stats for Pulsar Functions

2020-07-07 Thread GitBox
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