What determines how frequently metrics are written to the Storm UI? I seem to
be seeing a latency of ~2 minutes between updates.
Thanks,
Rick Magnuson
Sounds good. Thanks for your response. I will keep one eye on this feature.
发送自 Windows 10 版邮件<https://go.microsoft.com/fwlink/?LinkId=550986>应用
发件人: Jungtaek Lim<mailto:kabh...@gmail.com>
发送时间: 2016年8月2日 13:57
收件人: user@storm.apache.org<mailto:user@storm.apache.org>
主题: Re
ows 10 版邮件 <https://go.microsoft.com/fwlink/?LinkId=550986>应用
>
>
>
> *发件人: *Jungtaek Lim
> *发送时间: *2016年7月31日 14:44
> *收件人: *user@storm.apache.org
> *主题: *Re: Storm UI metrics data is cleared sometimes
>
>
> Hi Chen,
>
> Storm's built-in metrics are ac
送时间: 2016年7月31日 14:44
收件人: user@storm.apache.org<mailto:user@storm.apache.org>
主题: Re: Storm UI metrics data is cleared sometimes
Hi Chen,
Storm's built-in metrics are actually task heartbeat stored at ZK, and these
values are calculated from each task and task writes them to ZK
Hi Chen,
Storm's built-in metrics are actually task heartbeat stored at ZK, and these
values are calculated from each task and task writes them to ZK via
replacing (I mean overwrite).
If worker is killed and restarted, all metrics for tasks in worker are
reset to 0, and it overwrites previous valu
Hi buddies,
I find the storm ui statistic data will be cleared automatically after running
for a while.
Some emitted and transferred counts are reset to zero while some components are
not.
Did anyone meet the same problem?
You should probably use a parallelism value of 1, to have a single global
*LoggingMetricsConsumer.*
conf.registerMetricsConsumer(LoggingMetricsConsumer.class, 1);
It will write the metrics into $STORM_HOME/logs/metrics.log
2015-03-13 15:29 GMT+01:00 Nick R. Katsipoulakis :
> Thanks a lot Marti
Thanks a lot Martin. I will take a look at both of the links.
Cheers,
Nikos
2015-03-13 10:27 GMT-04:00 Martin Illecker :
> I believe the *LoggingMetricsConsumer* [1] will do the job.
>
> conf.registerMetricsConsumer(LoggingMetricsConsumer.class, 2);
>
>
> Have a look at this tutorial [2].
>
> [1
I believe the *LoggingMetricsConsumer* [1] will do the job.
conf.registerMetricsConsumer(LoggingMetricsConsumer.class, 2);
Have a look at this tutorial [2].
[1]
https://github.com/nathanmarz/storm/blob/master/storm-core/src/jvm/backtype/storm/metric/LoggingMetricsConsumer.java
[2] https://www.e
Hello all,
In Storm UI I can see the following metrics for each bolt/spout in an
active topology: Capacity and Latency. Is there a way to get those metrics
from the bolt's code and store them in a custom log file.
Thank you,
Nikos
--
Nikolaos Romanos Katsipoulakis,
University of Pittsburgh, Ph
10 matches
Mail list logo