Hi,

I was reading a bit of code about partitioning and I have two questions
about the forward() method of DataStream:

1) I was before under the impression that forwarding means sending
records between operators with same parallelism always from partition 1
to 1, 2 to 2 etc. But this doesn't seem the case because
ForwardPartitioner#selectChannels returns new int[] {0} - which is
interestingly the exact same code like GlobalPartitioner.
2) Why is there a forward()-statement anyways? Isn't this the default
that messages are forwarded between same partitions or am I getting
something completely wrong here? If so, how does it work and what would
be a good use case for the forward() statement?

Thanks,
Marius

Reply via email to