Hi, I'm afraid this is a bug. I open a Jira Issue for it: https://issues.apache.org/jira/browse/FLINK-3977
Cheers, Aljoscha On Thu, 26 May 2016 at 09:13 Erik <erikg...@gmail.com> wrote: > 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. >
