code: 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);
  		}
  	}
docs: 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