InputGate consumedSubpartitionIndex in ALL_TO_ALL distribution pattern

classic Classic list List threaded Threaded
2 messages Options
Reply | Threaded
Open this post in threaded view
|

InputGate consumedSubpartitionIndex in ALL_TO_ALL distribution pattern

Luís Alves
Hi!

Can someone confirm that the following statement is true: If we have a task consuming from two other tasks (both using ALL_TO_ALL distribution pattern). Then, this task will have two InputGates consuming from the same index (consumedSubpartitionIndex). This means that each task would always consume from the same consumedSubpartitionIndex independently of the InputGates (when using ALL_TO_ALL).

Thanks, 

Luís Alves
Reply | Threaded
Open this post in threaded view
|

Re: InputGate consumedSubpartitionIndex in ALL_TO_ALL distribution pattern

Stephan Ewen
Yes, that is true.

On Tue, Dec 20, 2016 at 12:46 PM, Luis Alves <[hidden email]> wrote:

> Hi!
>
> Can someone confirm that the following statement is true: If we have a
> task consuming from two other tasks (both using ALL_TO_ALL distribution
> pattern). Then, this task will have two InputGates consuming from the same
> index (consumedSubpartitionIndex). This means that each task would always
> consume from the same consumedSubpartitionIndex independently of the
> InputGates (when using ALL_TO_ALL).
>
> Thanks,
>
> Luís Alves