[jira] [Created] (FLINK-30366) Python Group Agg failed in cleaning the idle state

["Xingbo Huang (Jira)" <ji...@apache.org>]

Xingbo Huang created FLINK-30366:
------------------------------------

             Summary: Python Group Agg failed in cleaning the idle state
                 Key: FLINK-30366
                 URL: https://issues.apache.org/jira/browse/FLINK-30366
             Project: Flink
          Issue Type: Bug
          Components: API / Python
    Affects Versions: 1.15.3, 1.16.0
            Reporter: Xingbo Huang
            Assignee: Xingbo Huang
             Fix For: 1.17.0, 1.16.1, 1.15.4


{code:java}
# aggregate_fast.pyx
cpdef void on_timer(self, InternalRow key):
    if self.state_cleaning_enabled:
        self.state_backend.set_current_key(key) # The key must be a list, but it is a InternalRow here.
        accumulator_state = self.state_backend.get_value_state(
            "accumulators", self.state_value_coder)
        accumulator_state.clear()
        self.aggs_handle.cleanup() {code}



--
This message was sent by Atlassian Jira
(v8.20.10#820010)