[FLINK-4747] Instability due to pending processing timers on operator close

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.2.0
• Fix Version/s: 1.2.0
• Component/s: Runtime / Task
• Assignee: Stephan Ewen
• Reporter: Stephan Ewen
• Created: 05/Oct/16 14:02
• Updated: 05/Oct/16 22:20
• Resolved: 05/Oct/16 22:19

Description

Execution on finite streams can hit a concurrent processing time timer while closing operators, resulting in a timer exception.

With the recent change to eagerly report asynchronous exceptions from timers, this becomes visible even on shutdown.