flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Aljoscha Krettek <aljos...@apache.org>
Subject Re: Fold error when window evictor is set
Date Thu, 26 May 2016 07:48:23 GMT
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 <erikgast@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.
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message