Zhu Zhu created FLINK-14234: ------------------------------- Summary: All partition consumable events should be notified to SchedulingStrategy (SchedulerNG) Key: FLINK-14234 URL: https://issues.apache.org/jira/browse/FLINK-14234 Project: Flink Issue Type: Sub-task Components: Runtime / Coordination Affects Versions: 1.10.0 Reporter: Zhu Zhu Fix For: 1.10.0
{{SchedulingStrategy}} requires partition consumable notification to make scheduling decisions. According to {{SchedulingStrategy#onPartitionConsumable}} definition, all partition consumable events should be notified to {{SchedulingStrategy}}, including those from TMs (pipelined partitions consumable for data produced) and from within JM(blocking partitions consumable for producer finished). More details see [here|https://github.com/apache/flink/pull/9663#discussion_r326540913]. This can be helpful for a more flexible scheduling. -- This message was sent by Atlassian Jira (v8.3.4#803005)