Github user zd-project commented on a diff in the pull request:
https://github.com/apache/storm/pull/2763#discussion_r205907405
--- Diff:
storm-server/src/main/java/org/apache/storm/scheduler/blacklist/BlacklistScheduler.java
---
@@ -89,13 +89,8 @@ public void prepare(Map<String, Object> conf) {
cachedSupervisors = new HashMap<>();
blacklistHost = new HashSet<>();
-
StormMetricsRegistry.registerGauge("nimbus:num-blacklisted-supervisor", new
Callable<Integer>() {
- @Override
- public Integer call() throws Exception {
- //nimbus:num-blacklisted-supervisor + none blacklisted
supervisor = nimbus:num-supervisors
- return blacklistHost.size();
- }
- });
+ //nimbus:num-blacklisted-supervisor + none blacklisted supervisor
= nimbus:num-supervisors
--- End diff --
It looks to me that there's a typo: nimbus:num-blacklisted-supervisor +
non-blacklisted supervisor = nimbus:num-supervisors
---
