You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by pt...@apache.org on 2014/04/21 21:44:22 UTC
[23/50] [abbrv] git commit: use metricsTimeBucketSizeInSecs
consistently
use metricsTimeBucketSizeInSecs consistently
Project: http://git-wip-us.apache.org/repos/asf/incubator-storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-storm/commit/f8afa99c
Tree: http://git-wip-us.apache.org/repos/asf/incubator-storm/tree/f8afa99c
Diff: http://git-wip-us.apache.org/repos/asf/incubator-storm/diff/f8afa99c
Branch: refs/heads/master
Commit: f8afa99c3036918291c694163e81fd4f22e0460b
Parents: 71119ce
Author: wurstmeister <wu...@users.noreply.github.com>
Authored: Wed Feb 19 22:55:45 2014 +0000
Committer: wurstmeister <wu...@users.noreply.github.com>
Committed: Wed Feb 19 22:55:45 2014 +0000
----------------------------------------------------------------------
src/jvm/storm/kafka/KafkaSpout.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/f8afa99c/src/jvm/storm/kafka/KafkaSpout.java
----------------------------------------------------------------------
diff --git a/src/jvm/storm/kafka/KafkaSpout.java b/src/jvm/storm/kafka/KafkaSpout.java
index d097510..79e33fe 100644
--- a/src/jvm/storm/kafka/KafkaSpout.java
+++ b/src/jvm/storm/kafka/KafkaSpout.java
@@ -93,7 +93,7 @@ public class KafkaSpout extends BaseRichSpout {
}
return _kafkaOffsetMetric.getValueAndReset();
}
- }, 60);
+ }, _spoutConfig.metricsTimeBucketSizeInSecs);
context.registerMetric("kafkaPartition", new IMetric() {
@Override
@@ -105,7 +105,7 @@ public class KafkaSpout extends BaseRichSpout {
}
return concatMetricsDataMaps;
}
- }, 60);
+ }, _spoutConfig.metricsTimeBucketSizeInSecs);
}
@Override