storm-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Abhishek Raj <abhishek....@saavn.com>
Subject Re: Stateful topology hangs
Date Wed, 22 Feb 2017 21:41:07 GMT
Thanks for the quick response. I am using Storm 1.0.2 and the storm-kafka
version is 1.0.2 as well. The kafka version being used is 2.9.2 - 0.8.1.1


On Thu, Feb 23, 2017 at 3:04 AM, P. Taylor Goetz <ptgoetz@gmail.com> wrote:

> What version of Storm are you using? And which Kafka spout (i.e.
> storm-kafka or storm-kafka-client)?
>
> -Taylor
>
> On Feb 22, 2017, at 4:32 PM, Abhishek Raj <abhishek.raj@saavn.com> wrote:
>
> Hello, I am using storm's state management feature in a topology.
> The topology has a kafkaspout and a StatefulBolt which uses
> RedisKeyValueState. What I observe is that after some time of running
> smoothly, the spout just stops consuming from the kafka topic and
> the $checkpointspout stops emitting any checkpoint tuples. The topology
> just hangs and there are no error messages in the logs. The spout acts as
> if there are no more messages to consume even though there are. This
> happens very randomly and if I restart the topology the error may or may
> not come.
>
> Can anyone please help in debugging this? I tried searching on jira but
> couldn't find a bug related to this issue.
>
> Thanks,
>
> --
> Abhishek
>
>
>


-- 
Abhishek

Mime
View raw message