[FLINK-22596] Active timeout is not triggered if there were no barriers

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.13.0
• Fix Version/s: 1.14.0, 1.13.1
• Component/s: Runtime / Checkpointing
• Labels: pull-request-available
• Assignee: Dawid Wysakowicz
• Reporter: Dawid Wysakowicz
• Created: 07/May/21 12:50
• Updated: 28/Aug/21 11:19
• Resolved: 10/May/21 09:22

Description

The condition in the active timeout timer is often incorrect, because we do not reset the allBarriersReceivedFuture on barrier announcements.

Issue Links

• links to: GitHub Pull Request #15852