Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-10429 Redesign Flink Scheduling, introducing dedicated Scheduler component
  3. FLINK-14233

All task state changes should be notified to SchedulingStrategy (SchedulerNG)

    XMLWordPrintableJSON

Details

    • Sub-task
    • Status: Closed
    • Major
    • Resolution: Later
    • 1.10.0
    • None
    • Runtime / Coordination
    • None

    Description

      SchedulingStrategy requires task states to make scheduling decisions.
      At the moment, however, only FINISHED and FAILED states are notified.

      According to SchedulingStrategy#onExecutionStateChange definition, all task state changes should be notified to SchedulingStrategy, including those from TMs and from within JM.
      This can be helpful for a more flexible scheduling.

      Attachments

        Activity

          People

            Unassigned Unassigned
            zhuzh Zhu Zhu
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: