Package org.apache.flink.runtime.scheduler.slowtaskdetector

Interface SlowTaskDetectorListener

  • All Known Implementing Classes:
    SpeculativeScheduler
    public interface SlowTaskDetectorListener
    Component responsible for listening on 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.