Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-10151

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

    Details

      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.

       

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                azagrebin Andrey Zagrebin
                Reporter:
                azagrebin Andrey Zagrebin
              • Votes:
                0 Vote for this issue
                Watchers:
                3 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: