Hello,
The result contains (a,Map(3 -> rt)) because reduce prints all
intermediate results (sometimes called a "rolling reduce"). It's
designed this way, because Flink streams are generally infinite, so
there is no last element where you could print the "final" results.
However, you can use window
Hi, in flink,the datastream have reduce Transformations,but the result do
not satisfy for me,for example,val pairs2 =
env.fromCollection((Array(("a", Map(3->"rt")),("a", Map(4->"yt")),("b",
Map(5->"dfs")val re=
pairs2.keyBy(0).reduce((x1,x2)=>(x1._1,x2._2++x1._2))re.map
