[FLINK-13955] Integrate ContinuousFileReaderOperator with StreamTask mailbox execution model

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.11.0
• Component/s: Runtime / Task
• Labels: pull-request-available
• Assignee: Roman Khachatryan
• Reporter: Alex
• Created: 04/Sep/19 10:46
• Updated: 10/Feb/20 11:31
• Resolved: 10/Feb/20 11:30

Description

The ContinuousFileReaderOperator spawns an additional (reader) thread and coordinates actions with it via checkpointLock. The operator may block, waiting for a notification from the reader thread, potentially preventing progress in mailbox loop.

This is similar to AsyncWaitOperator situation described in FLINK-12958.

Issue Links

• links to: GitHub Pull Request #10435