storm-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Adam Honen <>
Subject Topology is stuck after upgrade to Storm 2.2.0 - how can I analyze what's going on?
Date Tue, 17 Nov 2020 14:08:10 GMT

I'm wondering what sort of metrics, logs, or other indications I can use in
order to understand why my topology gets stuck after ugrading from Storm
1.1.1 to Storm 2.2.0.

More in length:
I have a 1.1.1 cluster with 40 workers processing ~400K events/second.
It starts by reading from Kinesis via the AWS KCL and this is also used to
implement our own backpressure. That is, when the topology is overloaded
with tuples, we stop reading from Kinesis until enough progress has been
made (we've been able to checkpoint).
After that, we resume reading.

However, with so many workers we don't really see back pressure being
needed even when dealing with much larger event rates.

We've now created a similar cluster with storm 2.2.0 and I've tried
deploying our topology there.
However, what happens is that within a couple of seconds, no more Kinesis
records get read. The topology appears to be just waiting forever without
processing anything.

I would like to troubleshoot this, but I'm not sure where to collect data
My initial suspicion was that the new back pressure mechanism, now found in
Storm 2, might have kicked in and that I need to configure it in order to
resolve this issue. However, this is nothing more than a guess. I'm not
sure how I can actually prove or disprove this without lots of trail &

I've found some documentation about backpressure in the performance tuning
chapter of the documentation, but that only concentrates on configuration
parameters and doesn't give information about how to really understand
what's going on in a running topology.

View raw message