[FLINK-6859] StateCleaningCountTrigger should not delete timer

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.3.0
• Fix Version/s: 1.3.1, 1.4.0
• Component/s: Table SQL / API
• Assignee: sunjincheng
• Reporter: Fabian Hueske
• Created: 06/Jun/17 17:04
• Updated: 19/Jun/17 22:22
• Resolved: 19/Jun/17 22:22

Description

The StateCleaningCountTrigger which is used to clean-up inactive state should not delete timers, i.e.. not call deleteProcessingTimeTimer().
This is an expensive operation.

We should rather fire the timer and check if we need to clean the state or not.

What do you think sunjincheng121?

Issue Links

• links to: GitHub Pull Request #4085