diff --git a/conf/defaults.yaml b/conf/defaults.yaml index 2ed45991c2a..8dcb2d97041 100644 --- a/conf/defaults.yaml +++ b/conf/defaults.yaml @@ -196,6 +196,9 @@ worker.log.level.reset.poll.secs: 30 topology.worker.receiver.thread.count: 1 # Executor metrics reporting interval. +# Cause the ui only show built in metrics, we should keep sync with the built in metrics interval, +# also the metrics consumer's collecting interval. +# See topology.builtin.metrics.bucket.size.secs and storm.cluster.metrics.consumer.publish.interval.secs. executor.metrics.frequency.secs: 60 task.heartbeat.frequency.secs: 3 diff --git a/integration-test/config/storm.yaml b/integration-test/config/storm.yaml index eca352fb9a9..67784e7bb75 100644 --- a/integration-test/config/storm.yaml +++ b/integration-test/config/storm.yaml @@ -27,6 +27,10 @@ storm.messaging.netty.max_retries: 10 storm.messaging.netty.min_wait_ms: 1000 storm.messaging.netty.max_wait_ms: 5000 +# Executor metrics reporting interval, keep it short enough for cases fetching executors metrics +# through restful API +executor.metrics.frequency.secs: 3 + drpc.servers: - "node1" diff --git a/integration-test/src/test/java/org/apache/storm/st/DemoTest.java b/integration-test/src/test/java/org/apache/storm/st/DemoTest.java index 133014bfe27..feca17a1dce 100644 --- a/integration-test/src/test/java/org/apache/storm/st/DemoTest.java +++ b/integration-test/src/test/java/org/apache/storm/st/DemoTest.java @@ -54,6 +54,7 @@ public void testExclamationTopology() throws Exception { topo.submitSuccessfully(); final int minExclaim2Emits = 500; final int minSpountEmits = 10000; + //Keep the check time to be gt Config.EXECUTOR_METRICS_FREQUENCY_SECS. for(int i = 0; i < 10; ++i) { TopologyInfo topologyInfo = topo.getInfo(); log.info(topologyInfo.toString());