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

StateCleaningCountTrigger should not delete timer

    Details

    • 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 API & SQL
    • Labels:
      None

      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 sunjincheng?

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                sunjincheng121 sunjincheng
                Reporter:
                fhueske Fabian Hueske
              • Votes:
                0 Vote for this issue
                Watchers:
                3 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: