[FLINK-10151] [State TTL] Fix false recursion call in TransformingStateTableKeyGroupPartitioner.tryAddToSource

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.6.0
• Fix Version/s: 1.6.1, 1.7.0
• Component/s: Runtime / State Backends
• Labels: pull-request-available
• Assignee: Andrey Zagrebin
• Reporter: Andrey Zagrebin
• Created: 15/Aug/18 14:58
• Updated: 21/Aug/18 12:41
• Resolved: 21/Aug/18 12:41

Description

TransformingStateTableKeyGroupPartitioner currently calls tryAddToSource recursively but has to call the super method of extended StateTableKeyGroupPartitioner. It can lead to infinite recursion when full snapshot cleanup strategy is activated for heap backend in async snapshot mode. The HeapTtlStateTest should be also divided into sync and async mode test suites to catch the problem.

 

Issue Links

• links to: GitHub Pull Request #6563