You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2018/06/11 12:45:58 UTC
flink git commit: [hotfix][docs] Properly initialize scala variable
Repository: flink
Updated Branches:
refs/heads/master bc684bb7a -> 4224837e2
[hotfix][docs] Properly initialize scala variable
This closes #6143.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/4224837e
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/4224837e
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/4224837e
Branch: refs/heads/master
Commit: 4224837e2ee8452c6358e5111930f78bae94cbfc
Parents: bc684bb
Author: Nico Duldhardt <nd...@gmail.com>
Authored: Sun Jun 10 01:43:33 2018 +0200
Committer: zentol <ch...@apache.org>
Committed: Mon Jun 11 14:45:20 2018 +0200
----------------------------------------------------------------------
docs/dev/event_timestamps_watermarks.md | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/4224837e/docs/dev/event_timestamps_watermarks.md
----------------------------------------------------------------------
diff --git a/docs/dev/event_timestamps_watermarks.md b/docs/dev/event_timestamps_watermarks.md
index 79ac953..cb1c5d4 100644
--- a/docs/dev/event_timestamps_watermarks.md
+++ b/docs/dev/event_timestamps_watermarks.md
@@ -242,7 +242,7 @@ class BoundedOutOfOrdernessGenerator extends AssignerWithPeriodicWatermarks[MyEv
val maxOutOfOrderness = 3500L // 3.5 seconds
- var currentMaxTimestamp: Long
+ var currentMaxTimestamp: Long = _
override def extractTimestamp(element: MyEvent, previousElementTimestamp: Long): Long = {
val timestamp = element.getCreationTime()