flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Chesnay Schepler <ches...@apache.org>
Subject Re: Incremental aggregations - Example not working
Date Mon, 12 Dec 2016 14:37:52 GMT
Hello Matt,

This looks like a bug in the fold() function to me.

I'm adding Timo to the discussion, he can probably shed some light on this.

Regards,
Chesnay

On 12.12.2016 15:13, Matt wrote:
> In case this is important, if I remove the WindowFunction, and only 
> use the FoldFunction it works fine.
>
> I don't see what is wrong...
>
> On Mon, Dec 12, 2016 at 10:53 AM, Matt <dromitlabs@gmail.com 
> <mailto:dromitlabs@gmail.com>> wrote:
>
>     Hi,
>
>     I'm following the documentation [1] of window functions with
>     incremental aggregations, but I'm getting an "input mismatch" error.
>
>     The code [2] is almost identical to the one in the documentation,
>     at the bottom you can find the exact error.
>
>     What am I missing? Can you provide a working example of a fold
>     function with both a FoldFunction and a WindowFunction?
>
>     Regards,
>     Matt
>
>     [1]
>     https://ci.apache.org/projects/flink/flink-docs-master/dev/windows.html#windowfunction-with-incremental-aggregation
>     <https://ci.apache.org/projects/flink/flink-docs-master/dev/windows.html#windowfunction-with-incremental-aggregation>
>
>     [2] https://gist.github.com/cc7ed5570e4ce30c3a482ab835e3983d
>     <https://gist.github.com/cc7ed5570e4ce30c3a482ab835e3983d>
>
>


Mime
View raw message