[FLINK-24441] Block SourceReader when watermarks are out of alignment

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.15.0
• Component/s: Connectors / Common
• Labels: pull-request-available
• Assignee: Piotr Nowojski
• Reporter: Piotr Nowojski
• Created: 01/Oct/21 15:11
• Updated: 23/Jun/23 05:16
• Resolved: 14/Feb/22 10:24

Description

SourceReader should become unavailable once it's latest watermark is too far into the future

Issue Links

• causes: FLINK-32414 Watermark alignment will cause flink jobs to hang forever when any source subtask has no SourceSplit
• links to: GitHub Pull Request #18702