Re: Question about UDF randomly processed input row twice

2022-11-03 Thread Xinyi Yan
48, 54, 54, 48, 51, 56, 51, 53] and num -306603835. On Thu, Nov 3, 2022 at 3:04 AM yuxia wrote: > 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. > > B

Question about UDF randomly processed input row twice

2022-11-02 Thread Xinyi Yan
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