dianfu commented on code in PR #26798:
URL: https://github.com/apache/flink/pull/26798#discussion_r2207051407
##########
flink-python/pyflink/fn_execution/table/window_aggregate_fast.pxd:
##########
@@ -25,7 +25,7 @@ cdef class NamespaceAggsHandleFunctionBase:
cdef void retract(self, InternalRow input_data)
cpdef void merge(self, object namespace, list accumulators)
cpdef void set_accumulators(self, object namespace, list accumulators)
- cdef list get_accumulators(self)
+ cpdef list get_accumulators(self)
Review Comment:
I don't think this is possible... The code path is already covered by
existing tests. This exception reported in the JIRA just occurs occasionally.
The job could run succeed after failover.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
