Two potential bugs in Flink ML

Hi Flink Dev Team, I have two possible bugs to report for Flink ML Iteration. Flink v1.17.2 Flink ML v2.3.0 Java 11 Bug # 1 Implementing a UDF KeyedRichCoProcessFunction or CoFlatMapFunction inside IterationBody yields a “java.lang.ClassCastException: org.apache.flink.iteration.IterationRecord c

Re: Two potential bugs in Flink ML

estion, there have been Functions implementing the IterationListener interface in Flink ML[1] and I just manually verified that their onEpochWatermarkIncremented method can be invoked in the test cases. You may check whether there is any difference between your implementation and that in the Flin

Re: Two potential bugs in Flink ML

ache.org Subject: Re: Two potential bugs in Flink ML Hi Komal, Thanks for your example code! I found that Flink ML has a bug when it comes to keyed two input operators. I have submitted a PR to fix this bug and you can build the Flink ML library for your program according to its document after this PR