[
https://issues.apache.org/jira/browse/FLINK-29855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17629175#comment-17629175
]
Xinyi Yan commented on FLINK-29855:
---
Thank you to [~luoyuxia] for confirming the root cause of the
[
https://issues.apache.org/jira/browse/FLINK-29855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17628539#comment-17628539
]
Xinyi Yan commented on FLINK-29855:
---
In case someone is trying to repro it locally or is interested in
[
https://issues.apache.org/jira/browse/FLINK-29855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17628515#comment-17628515
]
Xinyi Yan commented on FLINK-29855:
---
I added a new UDF that randomly returns either null or bytes, and
[
https://issues.apache.org/jira/browse/FLINK-29855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17628437#comment-17628437
]
Xinyi Yan commented on FLINK-29855:
---
hi [~luoyuxia], I think this is a critical bug, and it can cause
[
https://issues.apache.org/jira/browse/FLINK-29855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17628431#comment-17628431
]
Xinyi Yan commented on FLINK-29855:
---
[~lsy], thanks for the reply. I don't think the datagen produces
[
https://issues.apache.org/jira/browse/FLINK-29855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17628327#comment-17628327
]
SenBin Lin commented on FLINK-29855:
Hi, Just for information. I modify the program provided by
[
https://issues.apache.org/jira/browse/FLINK-29855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17628226#comment-17628226
]
luoyuxia commented on FLINK-29855:
--
How do you know some of the data have been processed twice?
The
[
https://issues.apache.org/jira/browse/FLINK-29855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17628061#comment-17628061
]
dalongliu commented on FLINK-29855:
---
Do the results in the print table as expected?
> UDF randomly
