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 <dromitl...@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 > > [2] https://gist.github.com/cc7ed5570e4ce30c3a482ab835e3983d >
