[FLINK-5427] [docs] Fix code example in event_timestamps_watermarks.md This closes #3082
Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/1750b0dd Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/1750b0dd Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/1750b0dd Branch: refs/heads/release-1.2 Commit: 1750b0dda8c243a215dcd558baf36ea1053a4310 Parents: 758ea79 Author: fengyelei 00406569 <[email protected]> Authored: Mon Jan 9 18:37:59 2017 +0800 Committer: Stephan Ewen <[email protected]> Committed: Wed Jan 11 19:06:10 2017 +0100 ---------------------------------------------------------------------- docs/dev/event_timestamps_watermarks.md | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/1750b0dd/docs/dev/event_timestamps_watermarks.md ---------------------------------------------------------------------- diff --git a/docs/dev/event_timestamps_watermarks.md b/docs/dev/event_timestamps_watermarks.md index 8d152df..a16aa55 100644 --- a/docs/dev/event_timestamps_watermarks.md +++ b/docs/dev/event_timestamps_watermarks.md @@ -304,7 +304,7 @@ public class PunctuatedAssigner extends AssignerWithPunctuatedWatermarks<MyEvent @Override public Watermark checkAndGetNextWatermark(MyEvent lastElement, long extractedTimestamp) { - return element.hasWatermarkMarker() ? new Watermark(extractedTimestamp) : null; + return lastElement.hasWatermarkMarker() ? new Watermark(extractedTimestamp) : null; } } {% endhighlight %} @@ -318,7 +318,7 @@ class PunctuatedAssigner extends AssignerWithPunctuatedWatermarks[MyEvent] { } override def checkAndGetNextWatermark(lastElement: MyEvent, extractedTimestamp: Long): Watermark = { - if (element.hasWatermarkMarker()) new Watermark(extractedTimestamp) else null + if (lastElement.hasWatermarkMarker()) new Watermark(extractedTimestamp) else null } } {% endhighlight %}
