Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-5427

Typo in the event_timestamps_watermarks doc

    Details

      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;
      	}
      

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                Unassigned
                Reporter:
                barcahead Yelei Feng
              • Votes:
                0 Vote for this issue
                Watchers:
                3 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: