Hi, Navneeth. If you *key* your stream using stream.keyBy(…), this will logically split your input and all the records with the same key will be processed in the same operator instance. This is the default behavior in Flink for keyed streams and transparently handled.
You can read more about it in the documentation [1]. [1] https://ci.apache.org/projects/flink/flink-docs-stable/dev/stream/state/state.html#keyed-state-and-operator-state On Thu, Apr 23, 2020 at 7:44 AM Navneeth Krishnan <reachnavnee...@gmail.com> wrote: > Hi All, > > Is there a way for an upstream operator to know how the downstream > operator tasks are assigned? Basically I want to group my messages to be > processed on slots in the same node based on some key. > > Thanks >
