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)

Reply via email to