Github user zd-project commented on a diff in the pull request:

    https://github.com/apache/storm/pull/2771#discussion_r204917201
  
    --- Diff: 
storm-server/src/main/java/org/apache/storm/daemon/supervisor/Supervisor.java 
---
    @@ -312,7 +315,7 @@ public void launchDaemon() {
                 launch();
                 Utils.addShutdownHookWithForceKillIn1Sec(this::close);
     
    -            registerWorkerNumGauge("supervisor:num-slots-used-gauge", 
conf);
    +            registerGauge(name(SUPERVISOR, "num-slots-used-gauge"), () -> 
SupervisorUtils.supervisorWorkerIds(conf).size());
    --- End diff --
    
    Okay will refactor this.


---

Reply via email to