public interface InternalFailuresListener
ExecutionGraph
).
In contrast, there are also failures that are detected by the TaskManager, which are communicated
via JobMasterGateway.updateTaskExecutionState(TaskExecutionState)
.Modifier and Type | Method and Description |
---|---|
void |
notifyGlobalFailure(Throwable t) |
void |
notifyTaskFailure(ExecutionAttemptID attemptId,
Throwable t) |
void notifyTaskFailure(ExecutionAttemptID attemptId, Throwable t)
void notifyGlobalFailure(Throwable t)
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.