[FLINK-5427] Typo in the event_timestamps_watermarks doc

• Type: Bug
• Status: Closed
• Priority: Minor
• Resolution: Fixed
• Affects Version/s: 1.2.0
• Fix Version/s: 1.2.0, 1.3.0
• Component/s: Documentation
• Labels: documentation
• Assignee: Unassigned
• Reporter: Yelei Feng
• Created: 09/Jan/17 10:36
• Updated: 11/Jan/17 20:24
• Resolved: 11/Jan/17 20:24

Description

I was reading the watermark doc: https://ci.apache.org/projects/flink/flink-docs-release-1.2/dev/event_timestamps_watermarks.html
We should replace element with lastElement in the body of method checkAndGetNextWatermark:

public Watermark checkAndGetNextWatermark(MyEvent lastElement, long extractedTimestamp) {
		return element.hasWatermarkMarker() ? new Watermark(extractedTimestamp) : null;
	}

Issue Links

• links to: GitHub Pull Request #3082