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