Verify that you have a shuffleGrouping call on your last Bolt. I experienced
the exact same problem earlier this week.
builder.setSpout(KAFKA_SPOUT_NAME, new KafkaSpout(kafkaConfig));
builder.setBolt("echo-bolt", new
EchoBolt()).shuffleGrouping(KAFKA_SPOUT_NAME);
From: Florian Hussonnois [mailto:[email protected]]
Sent: Thursday, February 26, 2015 6:00 PM
To: [email protected]
Subject: Tuples never reach bolts
Hi,
Is someone already faced with tuples that never reach a bolt ?
On a project, we have deployed a topology composed of 1 kafka spout and 3 bolts
to a cluster.
Messages are read from a kafka queue. Then, tuples are handled by a json parser
bolt and re-emitted to a third bolt to be transformed. However the tuples seems
to never reach the last bolt.
Looking into storm UI, we have observed that 100% of our stream is redirected
to the bolt but its execute method is never called.
We have no error into the workers logs.
Thanks you a lot for your help.
--
Florian HUSSONNOIS
