flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Maximilian Michels <...@apache.org>
Subject Re: Error with window fold
Date Wed, 04 Nov 2015 13:47:00 GMT
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 <mxm@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 <gyfora@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

Mime
View raw message