Unsubscribe On Fri, Nov 13, 2020 at 10:54 AM Michael Giroux <[email protected]> wrote:
> 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! > > -- Thanks Ravindra Sadaphule
