storm-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Stepan Urban <>
Subject Re: LoggingMetricsConsumer stop logging
Date Thu, 01 Oct 2015 09:44:11 GMT
Hi Ahishek,
thanks for the response. Registring metrics is normal:
transient MultiCountMetric countMetric;
transient MultiReducedMetric meanMetric;

countMetric = new MultiCountMetric();
meanMetric = new MultiReducedMetric(new MeanReducer());
context.registerMetric("count", countMetric, 1);
context.registerMetric("mean", meanMetric, 1);

Config conf = new Config();
conf.registerMetricsConsumer(LoggingMetricsConsumer.class, 1);

even with default cluster.xml it stops logging on production computer.

Yesterday I found that everything work on dev computer with data loaded
from file. But on production computer, when data are receided from net it
stops logging after few hours. Is it possible to find if some thread is not
working properly using jstack? Or any other way how to debug it?


2015-10-01 6:26 GMT+02:00 Anishek Agarwal <>:

> From what i have found dont remove/add appenders in cluster.xml. not sure
> about why it works for a few hours and then stops. any specific way you are
> registering log metrics, is it possible to put some code out ?
> On Tue, Sep 29, 2015 at 9:14 PM, Stepan Urban <>
> wrote:
>> Hi,
>> I am using LoggingMetricsConsumer and MultiReducedMetric to count several
>> metrics in Storm topology. After few hours of running it stops logging
>> these metrics into metrics.log file without an error in any log file. Any
>> sugestions how to find where is the problem? First I used default
>> cluster.xml with increased size of files, now I use only
>> ch.qos.logback.core.FileAppender with the same results. After few mb of
>> logs it stops logging.
>> Thanks
>> Stepan

View raw message