Xuannan Su created FLINK-29231:
----------------------------------
Summary: PyFlink udtaf produces different results in the same
sliding window
Key: FLINK-29231
URL: https://issues.apache.org/jira/browse/FLINK-29231
Project: Flink
Issue Type: Bug
Components: API / Python
Affects Versions: 1.15.2
Reporter: Xuannan Su
Attachments: image-2022-09-08-17-20-06-296.png, input, test_agg.py
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:
!image-2022-09-08-17-20-06-296.png!
We can see that the output contains different `val_sum` at `window_time`
2022-01-01 00:01:59.999.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)