Re: Error with window fold

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 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

Re: Error with window fold

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 wrote: > That's basically what I also found out too so far. If you want to fix

Re: Error with window fold

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

Re: Error with window fold

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 wrote: > Hey, > > Running the following simple application gives me an error: > > //just counting by key, the > streamOfIntegers.keyBy(x

Re: Error with window fold

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 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

Re: Error with window fold

This was java 8, snapshot 1.0 :) Maximilian Michels 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 wrote: > > Hi

Error with window fold

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