flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Gyula Fóra <gyf...@apache.org>
Subject Error with window fold
Date Wed, 04 Nov 2015 12:49:52 GMT
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
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message