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)
