Hi,
I get a "No initial value was serialized for the fold window function.
Probably the setOutputmethod was not called" when I use the fold function on
a WindowedStream where an evictor has been set. If no evictor is set, it
works fine.
There was a similair issue
<http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/Error-with-window-fold-td8924.html>
before, but I thought that it was fixed.
Exampel code:
env.fromCollection[String](data).keyBy(0).window(GlobalWindows.create).evictor(CountEvictor.of(1)).trigger(CountTrigger.of(2)).fold[String]("")((s,r)
=> s+r).print()
I'm using version 1.0.3 and Scala.
Erik
--
View this message in context:
http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/Fold-error-when-window-evictor-is-set-tp11834.html
Sent from the Apache Flink Mailing List archive. mailing list archive at
Nabble.com.
