public void scheduleOrUpdateConsumers(ResultPartitionID partitionId) throws ExecutionGraphException {

		assertRunningInJobMasterMainThread();

		final Execution execution = currentExecutions.get(partitionId.getProducerId());

		if (execution == null) {
			throw new ExecutionGraphException("Cannot find execution for execution Id " +
				partitionId.getPartitionId() + '.');
		}
		else if (execution.getVertex() == null){
			throw new ExecutionGraphException("Execution with execution Id " +
				partitionId.getPartitionId() + " has no vertex assigned.");
		} else {
			execution.getVertex().scheduleOrUpdateConsumers(partitionId);
		}
	}
public void scheduleOrUpdateConsumers ( ResultPartitionID partitionId ) throws ExecutionGraphException { assertRunningInJobMasterMainThread ( ) ; final Execution execution = currentExecutions . get ( partitionId . getProducerId ( ) ) ; if ( execution == null ) { throw new ExecutionGraphException ( "Cannot find execution for execution Id " + partitionId . getPartitionId ( ) + '.' ) ; } else if ( execution . getVertex ( ) == null ) { throw new ExecutionGraphException ( "Execution with execution Id " + partitionId . getPartitionId ( ) + " has no vertex assigned." ) ; } else { execution . getVertex ( ) . scheduleOrUpdateConsumers ( partitionId ) ; } }
Schedule or updates consumers of the given result partition.

@param partitionId specifying the result partition whose consumer shall be scheduled or updated
@throws ExecutionGraphException if the schedule or update consumers operation could not be executed