[FLINK-20439] Simplifying scheduleOrUpdateConsumers

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Done
• Fix Version/s: 1.13.0
• Component/s: Runtime / Coordination
• Labels: pull-request-available
• Assignee: Zhu Zhu
• Reporter: Zhu Zhu
• Created: 01/Dec/20 09:09
• Updated: 23/Dec/20 18:23
• Resolved: 23/Dec/20 18:23

Description

JobMaster#scheduleOrUpdateConsumers() was used to schedule a vertex when its PIPELINED inputs have data produced.
It is not needed anymore in the latest pipelined region scheduling because PIPELINED upstream and downstream tasks will be scheduled all at once.

Issue Links

• links to: GitHub Pull Request #14462