Reconfigure barrier when more than one InputDataIngestionMode per operator.

lsds / SEEP

Cluster computing using Stateful Dataflow Graphs

26 stars 12 forks source link

Reconfigure barrier when more than one InputDataIngestionMode per operator. #3

Closed raulcf closed 11 years ago

raulcf commented 11 years ago

In particular, the problem is how to understand how many of the total number of upstream operators have to synchronise in the barrier. (These are those that have scaled out from the same original operator).