org.apache.flink.runtime.scheduler.slowtaskdetector

Interface SlowTaskDetector

All Known Implementing Classes:

ExecutionTimeBasedSlowTaskDetector

public interface SlowTaskDetector

Component responsible for detecting slow tasks.

Method Summary

Modifier and Type	Method and Description
void	start(ExecutionGraph executionGraph, SlowTaskDetectorListener listener, ComponentMainThreadExecutor mainThreadExecutor) Start detecting slow tasks periodically.
void	stop() Stop detecting slow tasks.

Method Detail

start

void start(ExecutionGraph executionGraph,
           SlowTaskDetectorListener listener,
           ComponentMainThreadExecutor mainThreadExecutor)

Start detecting slow tasks periodically.

stop

void stop()

Stop detecting slow tasks.