public class UpdateSchedulerNgOnInternalFailuresListener extends Object implements InternalFailuresListener
SchedulerNG.updateTaskExecutionState(TaskExecutionStateTransition)
on task failure.
Calls GlobalFailureHandler.handleGlobalFailure(Throwable)
on global failures.Constructor and Description |
---|
UpdateSchedulerNgOnInternalFailuresListener(SchedulerNG schedulerNg) |
Modifier and Type | Method and Description |
---|---|
void |
notifyGlobalFailure(Throwable t) |
void |
notifyTaskFailure(ExecutionAttemptID attemptId,
Throwable t,
boolean cancelTask,
boolean releasePartitions) |
public UpdateSchedulerNgOnInternalFailuresListener(SchedulerNG schedulerNg)
public void notifyTaskFailure(ExecutionAttemptID attemptId, Throwable t, boolean cancelTask, boolean releasePartitions)
notifyTaskFailure
in interface InternalFailuresListener
public void notifyGlobalFailure(Throwable t)
notifyGlobalFailure
in interface InternalFailuresListener
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.