[FLINK-17542] Unify slot request timeout handling for streaming and batch tasks

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Abandoned
• Affects Version/s: 1.11.0
• Fix Version/s: 1.12.0
• Component/s: Runtime / Coordination
• Labels: pull-request-available
• Assignee: Zhu Zhu
• Reporter: Zhu Zhu
• Created: 06/May/20 12:55
• Updated: 25/May/20 06:28
• Resolved: 25/May/20 06:28

Description

There are 2 different slot request timeout handling mechanism for batch and streaming tasks.
For streaming tasks, the slot request will fail if it is not fulfilled within slotRequestTimeout.
For batch tasks, the slot request will be checked periodically to see whether it is fulfillable, and only fails if it has been unfulfillable for a certain period(slotRequestTimeout).

With slot marked with whether they will be occupied indefinitely, we can unify these handling. See FLIP-119 for more details.

Issue Links

• links to: GitHub Pull Request #12011