Fold error when window evictor is set

[Erik]

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 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

[Aljoscha Krettek-2]

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 <[hidden email]> 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.
>