flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Nicaz <Walte...@students.uni-marburg.de>
Subject Forward Partitioning & same Parallelism: 1:1 communication?
Date Tue, 11 Aug 2015 21:41:25 GMT

I have a question about forward partitioning in Flink.

If Operator A and Operator B have the same parallelism set and forward
partitioning is used for events coming from instances of A and going to
instances of B:

Will each instance of A send events to _exactly one_ instance of B?

That is, will all events coming from a specific instance of A go to the
_same_ specific instance of B, and will _all_ instances of B be used?
Or are there any situations where an instance of A will distribute events to
several different instances of B, or where two instances of A will send
events to the same instance of B (possibly leaving some other instance of B

I'd be very happy if someone were able to shed some light on this issue. :-)

Thanks in advance

View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Forward-Partitioning-same-Parallelism-1-1-communication-tp2373.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.

View raw message