Re: Question about UDF randomly processed input row twice

n the StreamPhysicalCalc, as of result of which, it seems the one row will be processed for twice. Best regards, Yuxia 发件人: "Xinyi Yan" 收件人: "yuxia" 抄送: "User" 发送时间: 星期五, 2022年 11 月 04日 上午 5:28:30 主题: Re: Question about UDF randomly processed input row twice O

Re: Question about UDF randomly processed input row twice

est regards, > Yuxia > > -- > *发件人: *"Xinyi Yan" > *收件人: *"User" > *发送时间: *星期四, 2022年 11 月 03日 上午 6:59:20 > *主题: *Question about UDF randomly processed input row twice > > Hi all, > I found a weird UDF behavior, and i

Re: Question about UDF randomly processed input row twice

The dategen may produce rows with same values. >From my side, in Flink, the udf shouldn't process one row for twice, >otherwise, it should be a critical bug. Best regards, Yuxia 发件人: "Xinyi Yan" 收件人: "User" 发送时间: 星期四, 2022年 11 月 03日 上午 6:59:20

Question about UDF randomly processed input row twice

Hi all, I found a weird UDF behavior, and it's a single thread that processes UDF twice, see FLINK-29855 for more details. Basically, I created a datagen table with a random integer (1 row per second) and passed this value into the UDF. Inside UDF