Ahh, there are no fold tests for the aligned time window operators. If you use Ingestion time or event time as stream characteristic it works correctly.
On Wed, Nov 4, 2015, 15:23 Maximilian Michels <m...@apache.org> wrote: > 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 > >> > > >> >
