org.apache.flink.runtime.scheduler.slowtaskdetector

Interface SlowTaskDetectorListener

All Known Implementing Classes:

DefaultSpeculativeExecutionHandler

public interface SlowTaskDetectorListener

Component responsible for listening on slow tasks.

Method Summary

Modifier and Type	Method and Description
void	notifySlowTasks(Map<ExecutionVertexID,Collection<ExecutionAttemptID>> slowTasks) Notify detected slow tasks.

Method Detail

notifySlowTasks

void notifySlowTasks(Map<ExecutionVertexID,Collection<ExecutionAttemptID>> slowTasks)

Notify detected slow tasks.

Parameters:

slowTasks - the map of execution vertices and their execution attempts which are detected as slow.