Page History

...

Two executions of a upstream ExecutionVertex will produce two ResultPartitions. When the all upstream ExecutionVertex ExecutionVertexs finished, we will update the inputChannel of down stream execution executions will be updated to consume the fastest finished execution of upstream.
when the down stream execution meet DataConsumptionException. It will restart with the upstream execution that has been finishedSo add a member-variable named fastestFinishedExecution in ExecutionVertex used for create PartitionInfo which used for update down stream executions' inputChannels.

public class ExecutionVertex
        implements AccessExecutionVertex, Archiveable<ArchivedExecutionVertex> {
	private Execution fastestFinishedExecution = null;
}

when the down stream execution meet DataConsumptionException. It will restart with the upstream execution that has been finished.

这里要画一张图。把failover的情况加进去，特别是下游带着上游重启的情况。

...