Hello, all,
I have a topology with 16 workers running across 4 nodes. This topology has a
bolt "transform" with executors=1 producing a stream that is comsumed by a bolt
"ontology" with executors=160. Everything is configured as shufflegrouping.
With Storm 1.2.3 all of the "ontology" bolts get their fair share of tuples.
When I run Storm 2.2.0 only the "ontology" bolts that are on the same node as
the single "transform" bolt get tuples.
Same cluster - same baseline code - only difference is binding in the new maven
artifact.
No errors in the logs.
Any thoughts would be welcome. Thanks!
