[FLINK-15076] Source thread should be interrupted during the Task cancellation

• Type: Bug
• Status: Closed
• Priority: Blocker
• Resolution: Fixed
• Affects Version/s: 1.9.1
• Fix Version/s: 1.9.2, 1.10.0
• Component/s: Runtime / Task
• Labels: pull-request-available
• Assignee: Piotr Nowojski
• Reporter: Piotr Nowojski
• Created: 05/Dec/19 10:54
• Updated: 19/Dec/19 10:54
• Resolved: 10/Dec/19 15:12

Description

Source thread should be interrupted more or less the same way how task thread is being interrupted.

+/- The `StreamTaskTest#testCancellationNotBlockedOnLock` should also work in case if the mailbox (task) thread is blocked on trying to acquire a `checkpointLock` by some other currently being executed mail (processing time timer/perform checkpoint).

https://github.com/apache/flink/pull/10345#discussion_r353615760

Issue Links

• causes: FLINK-15317 State TTL Heap backend end-to-end test fails on Travis
• links to: GitHub Pull Request #10446
• links to: GitHub Pull Request #10511