You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@storm.apache.org by Vadim Smirnov <v2...@mail.ru> on 2014/11/14 15:35:51 UTC
Re[2]: How get metrics value from Spout code ? I am want something like 'static' across topology.
Unfortunate, it is all about as create metrics and read it outside. I am want read metric value from Spout code.
Fri, 14 Nov 2014 08:43:57 -0500 от Otis Gospodnetic <ot...@gmail.com>:
>Hi Vadim,
>
>Check a list of Storm metrics listed in http://blog.sematext.com/2014/01/30/announcement-apache-storm-monitoring-in-spm/ -- I think some of them may be what you are after, though presented as rates/throughput vs. a single total number. Alternatively, have a look at http://www.endgame.com/blog/storm-metrics-how-to.html .
>
>Otis
>--
>Monitoring * Alerting * Anomaly Detection * Centralized Log Management
>Solr & Elasticsearch Support * http://sematext.com/
>
>
>On Fri, Nov 14, 2014 at 8:00 AM, Vadim Smirnov < v2smirnov@mail.ru > wrote:
>>I am have several input Spout and several output Bolts. I am want know how many tuples already processed. For it i am create metric an .incr() it on output Bolt .execute(). How i am can read metric value from Spout code ?
>
Re: Re[2]: How get metrics value from Spout code ? I am want
something like 'static' across topology.
Posted by Devang Shah <de...@gmail.com>.
May be try reading it from the STORM UI using REST Api.
Thanks and Regards,
Devang
On 16 Nov 2014 15:37, "Vladi Feigin" <vl...@gmail.com> wrote:
> Hi,
>
> Maybe you can override spout ack/fail method ant take it from there . In
> case you use ackers
> Vladi
>
> On Fri, Nov 14, 2014 at 4:35 PM, Vadim Smirnov <v2...@mail.ru> wrote:
>
>> Unfortunate, it is all about as create metrics and read it outside. I am
>> want read metric value from Spout code.
>>
>>
>> Fri, 14 Nov 2014 08:43:57 -0500 от Otis Gospodnetic <
>> otis.gospodnetic@gmail.com>:
>>
>> Hi Vadim,
>>
>> Check a list of Storm metrics listed in
>> http://blog.sematext.com/2014/01/30/announcement-apache-storm-monitoring-in-spm/
>> -- I think some of them may be what you are after, though presented as
>> rates/throughput vs. a single total number. Alternatively, have a look at
>> http://www.endgame.com/blog/storm-metrics-how-to.html .
>>
>> Otis
>> --
>> Monitoring * Alerting * Anomaly Detection * Centralized Log Management
>> Solr & Elasticsearch Support * http://sematext.com/
>>
>>
>> On Fri, Nov 14, 2014 at 8:00 AM, Vadim Smirnov <v2smirnov@mail.ru
>> <ht...@mail.ru>> wrote:
>>
>> I am have several input Spout and several output Bolts. I am want know
>> how many tuples already processed. For it i am create metric an .incr() it
>> on output Bolt .execute(). How i am can read metric value from Spout code ?
>>
>>
>>
>>
>
Re: Re[2]: How get metrics value from Spout code ? I am want
something like 'static' across topology.
Posted by Vladi Feigin <vl...@gmail.com>.
Hi,
Maybe you can override spout ack/fail method ant take it from there . In
case you use ackers
Vladi
On Fri, Nov 14, 2014 at 4:35 PM, Vadim Smirnov <v2...@mail.ru> wrote:
> Unfortunate, it is all about as create metrics and read it outside. I am
> want read metric value from Spout code.
>
>
> Fri, 14 Nov 2014 08:43:57 -0500 от Otis Gospodnetic <
> otis.gospodnetic@gmail.com>:
>
> Hi Vadim,
>
> Check a list of Storm metrics listed in
> http://blog.sematext.com/2014/01/30/announcement-apache-storm-monitoring-in-spm/
> -- I think some of them may be what you are after, though presented as
> rates/throughput vs. a single total number. Alternatively, have a look at
> http://www.endgame.com/blog/storm-metrics-how-to.html .
>
> Otis
> --
> Monitoring * Alerting * Anomaly Detection * Centralized Log Management
> Solr & Elasticsearch Support * http://sematext.com/
>
>
> On Fri, Nov 14, 2014 at 8:00 AM, Vadim Smirnov <v2smirnov@mail.ru
> <ht...@mail.ru>> wrote:
>
> I am have several input Spout and several output Bolts. I am want know how
> many tuples already processed. For it i am create metric an .incr() it on
> output Bolt .execute(). How i am can read metric value from Spout code ?
>
>
>
>