Hi,

While working with Apache Storm 0.9.4 with python + multilang, I found that
one tuple was hanging the topology. It took me a while to figure what's
going on and why it stopped processing payloads until I found that the
hanged bolt was blocked waiting from input on its stdin (it hangs calling
emit).

After inspecting the tuple that hanged it I found that it includes a json
string that is about 75KB long, it's valid JSON so it's not corrupted but
for some reason breaks when it's emitted.

I'm using Kafka as a way to inject tuples into my topology and the
KafkaSpout is able to inject such tuple so I wonder whether it's just a
limitation of the multilang implementation...

Is there any hint to debug or fix it?

The worse thing is that there was no errors on the supervisor nor workers
logs I just found this because I inspected the processes manually with
strace and adding log output on my code to find the place where it hanged.

Thanks in advance!

-- 

Carlos Perelló Marínhttps://www.serverdensity.com

Reply via email to