[FLINK-29231] PyFlink UDAF produces different results in the same sliding window

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.15.3
• Fix Version/s: 1.17.0, 1.16.1, 1.15.4
• Component/s: API / Python
• Labels: pull-request-available
• Assignee: Dian Fu
• Reporter: Xuannan Su
• Created: 08/Sep/22 12:21
• Updated: 16/Jan/23 04:36
• Resolved: 16/Jan/23 04:36

Description

It seems that PyFlink udtaf produces different results in the same sliding window. It can be reproduced with the given code and input. It is not always happening but the possibility is relatively high.

The incorrect output is the following:

 

We can see that the output contains different `val_sum` at `window_time` 2022-01-01 00:01:59.999.

Issue Links

• links to: GitHub Pull Request #21655