[FLINK-11004] Wrong ProcessWindowFunction.process argument in example of Incremental Window Aggregation with ReduceFunction

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.4.2, 1.5.5, 1.6.2
• Component/s: Documentation
• Labels: pull-request-available
• Assignee: Unassigned
• Reporter: Yuanyang Wu
• Created: 26/Nov/18 13:00
• Updated: 28/Nov/18 09:21
• Resolved: 28/Nov/18 09:21

Description

https://ci.apache.org/projects/flink/flink-docs-release-1.6/dev/stream/operators/windows.html#incremental-window-aggregation-with-reducefunction

Example use wrong "window" argument in process()

JAVA example

- out.collect(new Tuple2<Long, SensorReading>(window.getStart(), min));

+ out.collect(new Tuple2<Long, SensorReading>(context.window().getStart(), min));

 

Scala example 2nd argument should be context:Context instead of window

 

Issue Links

• links to: GitHub Pull Request #7175