pystorm/streamparse

Secondary tuple from secondary inputs are never received.

NoahLiot opened this issue · 1 comments

NoahLiot commented

I am trying to send tuples from 2 bolts to 1 bolt.
If in the topology, I map them 1 to 1, everything gets processed as it should.
but when in the topology I do:

NewsAlertFactoryBolt1 = NewsAlertFactoryBolt.spec(inputs={NewsAnalyticsPayloadBolt1: Grouping.SHUFFLE, NewsEnrichementBolt1: Grouping.SHUFFLE}, par=2)

I get the tuples from NewsAnalyticsPayloadBolt1 but I never receive the one from NewsEnrichementBolt1

NoahLiot commented

Found, the issue. Apologise.