[
https://issues.apache.org/jira/browse/FLINK-29231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingbo Huang reassigned FLINK-29231:
------------------------------------
Assignee: Xingbo Huang
> 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
> Assignee: Xingbo Huang
> Priority: Major
> 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)
