Hi, I have a pipeline which looks like this - Input -> Convert_to_KV_pairsDoFn -> SomeStatefulDofn -> output As you can see there is no explicit "shuffle" transform here
My understanding and observation so far has been that the SomeStatefulDofn will never be executed in parallel on two workers for any given key. Is my understanding correct? If yes, then second question - is there an implicit groupByKey kind of step introduced by dataflow here to ensure that all msges with same key goes to same worker?
