You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by bo...@apache.org on 2016/04/01 16:07:45 UTC
[22/35] storm git commit: update
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 <xi...@alibaba-inc.com>
Authored: Thu Mar 24 01:29:20 2016 +0800
Committer: xiaojian.fxj <xi...@alibaba-inc.com>
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);