I have a fix for it. Will open a PR. On Wed, Nov 4, 2015 at 3:31 PM, Aljoscha Krettek <aljos...@apache.org> wrote:
> 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 > > >> > > > >> > > >
