Hey, I was hoping that someone can answer this right away without me having to dig through all the code :)
How does the channel indexing go when more then one consumer subtask is connected to an intermediate dataset in the pointwise pattern? I am trying to figure out which one is the “in-memory” channel to set up proper partitioning for streams in this case. The idea would be to push the majority to the in memory channel while still push some messages to the network channel to leverage operator parallelism, but to implement this I need to figure out the index of the in-memory channel. Thank you, Gyula
