Package org.apache.flink.runtime.scheduler.adaptivebatch

Interface SpeculativeExecutionHandler

All Known Implementing Classes:

DefaultSpeculativeExecutionHandler, DummySpeculativeExecutionHandler

public interface SpeculativeExecutionHandler

Interface for managing speculative execution of tasks and handling slow task detection.

Method Summary

Modifier and Type	Method	Description
boolean	handleTaskFailure(Execution failedExecution, Throwable error, BiConsumer<Execution,Throwable> handleLocalExecutionAttemptFailure)	Handles a task failure.
void	init(ExecutionGraph executionGraph, ComponentMainThreadExecutor mainThreadExecutor, MetricGroup metricGroup)	Initial speculative execution handler.
void	notifyTaskFailed(Execution execution)	Notifies that a task has failed its execution.
void	notifyTaskFinished(Execution execution, Function<ExecutionVertexID,CompletableFuture<?>> cancelPendingExecutionsFunction)	Notifies that a task has finished its execution.
void	resetForNewExecution(ExecutionVertexID executionVertexId)	Resets the state of the component for a new execution of a specific execution vertex.
void	stopSlowTaskDetector()	Stops the slow task detector.

Method Detail

init

void init(ExecutionGraph executionGraph,
          ComponentMainThreadExecutor mainThreadExecutor,
          MetricGroup metricGroup)

Initial speculative execution handler.

stopSlowTaskDetector

void stopSlowTaskDetector()

Stops the slow task detector.

notifyTaskFinished

void notifyTaskFinished(Execution execution,
                        Function<ExecutionVertexID,CompletableFuture<?>> cancelPendingExecutionsFunction)

Notifies that a task has finished its execution.

Parameters:

execution - the execution that has finished

cancelPendingExecutionsFunction - the function to cancel pending executions

notifyTaskFailed

void notifyTaskFailed(Execution execution)

Notifies that a task has failed its execution.

Parameters:

execution - the execution that has failed

handleTaskFailure

boolean handleTaskFailure(Execution failedExecution,
                          @Nullable
                          Throwable error,
                          BiConsumer<Execution,Throwable> handleLocalExecutionAttemptFailure)

Handles a task failure.

Parameters:

failedExecution - the execution that failed

error - the error that caused the failure, if available

handleLocalExecutionAttemptFailure - a consumer that handles local execution attempt failure

Returns:

true if the failure was handled as a local failure, false otherwise

resetForNewExecution

void resetForNewExecution(ExecutionVertexID executionVertexId)

Resets the state of the component for a new execution of a specific execution vertex.

Parameters:

executionVertexId - the ID of the execution vertex to reset