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.f...@gmail.com> wrote: > This was java 8, snapshot 1.0 :) > > Maximilian Michels <m...@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 <m...@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 <gyf...@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 > > >
