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 .