Re: ValueState in RichCoFlatMap, possible 1.2-SNAPSHOT regression

Hi, the problem is this line > object FlatMapper extends RichCoFlatMapFunction[Long, String, (Long, String)] > { which should use „class" instead of „object". Otherwise, one singleton instance of the FlatMapper is used by Flink across multiple operator instances, which leads to the whole

ValueState in RichCoFlatMap, possible 1.2-SNAPSHOT regression

Hi all, I was trying to implement a join similar to what was laid out in the flink forward talk Joining Infinity: Windowless Stream Processing with Flink and I have been running to some issues. I am