You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@storm.apache.org by Tomas Mazukna <to...@gmail.com> on 2014/09/23 22:54:21 UTC
Tick Tuples stop coming?
config.put(Config.TOPOLOGY_TICK_TUPLE_FREQ_SECS, 60);
submit topology and after about 4 hours tick tuples just stop...
How to trouble shoot this?
I am detecting tick like this:
if( input.getSourceStreamId().equals("__tick")) {
LOG.error( "TICK TUPLE RECEIVED" );
and I stop seeing tick tuples in the log.
collector.ack(input);
is at the end of every one execute() method.
--
Tomas Mazukna
678-557-3834
Re: Tick Tuples stop coming?
Posted by Tomas Mazukna <to...@gmail.com>.
Which thread I am looking for?
The messages from spout are flowing, acks are happening, topology is
processing data stream...
Every minute it is supposed to dump stats onto Kafka topic.
Thanks for suggestion!
On Tue, Sep 23, 2014 at 8:23 PM, Srinath C <sr...@gmail.com> wrote:
> Maybe you could take a thread dump and check if storm's executor threads
> are stuck on a blocking call.
>
>
>
> On Wed, Sep 24, 2014 at 2:24 AM, Tomas Mazukna <to...@gmail.com>
> wrote:
>
>>
>> config.put(Config.TOPOLOGY_TICK_TUPLE_FREQ_SECS, 60);
>>
>>
>> submit topology and after about 4 hours tick tuples just stop...
>> How to trouble shoot this?
>>
>> I am detecting tick like this:
>>
>>
>> if( input.getSourceStreamId().equals("__tick")) {
>> LOG.error( "TICK TUPLE RECEIVED" );
>>
>> and I stop seeing tick tuples in the log.
>>
>> collector.ack(input);
>>
>> is at the end of every one execute() method.
>>
>> --
>> Tomas Mazukna
>> 678-557-3834
>>
>
>
--
Tomas Mazukna
678-557-3834
Re: Tick Tuples stop coming?
Posted by Srinath C <sr...@gmail.com>.
Maybe you could take a thread dump and check if storm's executor threads
are stuck on a blocking call.
On Wed, Sep 24, 2014 at 2:24 AM, Tomas Mazukna <to...@gmail.com>
wrote:
>
> config.put(Config.TOPOLOGY_TICK_TUPLE_FREQ_SECS, 60);
>
>
> submit topology and after about 4 hours tick tuples just stop...
> How to trouble shoot this?
>
> I am detecting tick like this:
>
>
> if( input.getSourceStreamId().equals("__tick")) {
> LOG.error( "TICK TUPLE RECEIVED" );
>
> and I stop seeing tick tuples in the log.
>
> collector.ack(input);
>
> is at the end of every one execute() method.
>
> --
> Tomas Mazukna
> 678-557-3834
>