That's basically what I also found out too so far. If you want to fix it please go ahead.
On Wed, Nov 4, 2015 at 3:11 PM, Till Rohrmann <trohrm...@apache.org> wrote: > 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 >> > >>
