update
Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/724f5d2c Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/724f5d2c Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/724f5d2c Branch: refs/heads/master Commit: 724f5d2cea8debea8c6fb6a0d42d275880636834 Parents: f03b8be Author: xiaojian.fxj <[email protected]> Authored: Thu Mar 24 01:29:20 2016 +0800 Committer: xiaojian.fxj <[email protected]> Committed: Thu Mar 24 01:29:20 2016 +0800 ---------------------------------------------------------------------- .../src/jvm/org/apache/storm/daemon/supervisor/Supervisor.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/724f5d2c/storm-core/src/jvm/org/apache/storm/daemon/supervisor/Supervisor.java ---------------------------------------------------------------------- diff --git a/storm-core/src/jvm/org/apache/storm/daemon/supervisor/Supervisor.java b/storm-core/src/jvm/org/apache/storm/daemon/supervisor/Supervisor.java index 1dd44a9..2b5078b 100644 --- a/storm-core/src/jvm/org/apache/storm/daemon/supervisor/Supervisor.java +++ b/storm-core/src/jvm/org/apache/storm/daemon/supervisor/Supervisor.java @@ -156,7 +156,7 @@ public class Supervisor { } private void registerWorkerNumGauge(String name, final Map conf) { - StormMetricsRegistry.registerGauge("supervisor:num-slots-used-gauge", new Callable<Integer>() { + StormMetricsRegistry.registerGauge(name, new Callable<Integer>() { @Override public Integer call() throws Exception { Collection<String> pids = SupervisorUtils.supervisorWorkerIds(conf);
