public interface InternalExecutionGraphAccessor
ClassLoader getUserClassLoader()
JobID getJobID()
BlobWriter getBlobWriter()
Either<SerializedValue<JobInformation>,PermanentBlobKey> getJobInformationOrBlobKey()
TaskDeploymentDescriptorFactory.PartitionLocationConstraint getPartitionLocationConstraint()
Executor getFutureExecutor()
@Nonnull ComponentMainThreadExecutor getJobMasterMainThreadExecutor()
ShuffleMaster<?> getShuffleMaster()
JobMasterPartitionTracker getPartitionTracker()
void registerExecution(Execution exec)
void deregisterExecution(Execution exec)
PartitionReleaseStrategy getPartitionReleaseStrategy()
void vertexFinished()
void vertexUnFinished()
ExecutionDeploymentListener getExecutionDeploymentListener()
void failGlobal(Throwable t)
This global failure is meant to be triggered in cases where the consistency of the execution graph' state cannot be guaranteed any more (for example when catching unexpected exceptions that indicate a bug or an unexpected call race), and where a full restart is the safe way to get consistency back.
t
- The exception that caused the failure.void notifyExecutionChange(Execution execution, ExecutionState newExecutionState)
void notifySchedulerNgAboutInternalTaskFailure(ExecutionAttemptID attemptId, Throwable t, boolean cancelTask, boolean releasePartitions)
EdgeManager getEdgeManager()
ExecutionVertex getExecutionVertexOrThrow(ExecutionVertexID id)
IntermediateResultPartition getResultPartitionOrThrow(IntermediateResultPartitionID id)
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.