flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Till Rohrmann <trohrm...@apache.org>
Subject Re: Error with window fold
Date Wed, 04 Nov 2015 14:11:20 GMT
The error should also be in 0.10. The problem is that due to the latest
stream refactorings we not only have fold operations which are
StreamOperators but also WindowFunctions (if you apply them on windows).
For the StreamOperators the output type is correctly set in the StreamGraph
and thus the initial value can be serialized. For the latter case the
function is part of the AccumulatingProcessingTimeWindowOperator which does
not implement the OutputTypeConfigurable interface. However, the
FoldWindowFunction does, which does not make sense at the moment, because
the WindowFunctions are not checked whether they implement the
OutputTypeConfigurable interface or not. I think this has to be added.

Cheers,

Till
​

On Wed, Nov 4, 2015 at 2:54 PM, Gyula Fóra <gyula.fora@gmail.com> wrote:

> This was java 8, snapshot 1.0 :)
>
> Maximilian Michels <mxm@apache.org> ezt írta (időpont: 2015. nov. 4., Sze,
> 14:47):
>
> > It's a bug. It also occurs in the Java API. Perhaps we can find a fix
> > for the release..
> >
> > On Wed, Nov 4, 2015 at 2:40 PM, Maximilian Michels <mxm@apache.org>
> wrote:
> > > Hi Gyula,
> > >
> > > Trying to reproduce this error now. I'm assuming this is 0.10-SNAPSHOT?
> > >
> > > Cheers,
> > > Max
> > >
> > > On Wed, Nov 4, 2015 at 1:49 PM, Gyula Fóra <gyfora@apache.org> wrote:
> > >> Hey,
> > >>
> > >> Running the following simple application gives me an error:
> > >>
> > >> //just counting by key, the
> > >> streamOfIntegers.keyBy(x ->
> > x).timeWindow(Time.milliseconds(3000)).fold(0, (
> > >> c, next) -> c + 1).print();
> > >>
> > >> Executing this gives the following error:
> > >>
> > >> "No initial value was serialized for the fold window function.
> Probably
> > the
> > >> setOutputType method was not called."
> > >>
> > >> Any idea?
> > >>
> > >> Cheers,
> > >>
> > >> Gyula
> >
>

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