[FLINK-22573] AsyncIO can timeout elements after completion

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.11.3, 1.13.0, 1.14.0, 1.12.3
• Fix Version/s: 1.14.0, 1.13.1, 1.12.4
• Component/s: API / DataStream
• Labels: pull-request-available
• Assignee: Arvid Heise
• Reporter: Arvid Heise
• Created: 05/May/21 09:53
• Updated: 28/May/21 11:09
• Resolved: 06/May/21 06:05

Description

AsyncIO emits completed elements over the mailbox at which any timer is also canceled. However, if the mailbox cannot process (heavy backpressure), it may be that the timer still triggers on a completed element.

Issue Links

• links to: GitHub Pull Request #15836
• links to: GitHub Pull Request #15841
• links to: GitHub Pull Request #15842