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

Revise the description of watermark strategy in Flink Table document

    XMLWordPrintableJSON

    Details

      Description

      The description of watermark strategy is wrong in doc[1]

      • Strictly ascending timestamps: WATERMARK FOR rowtime_column AS rowtime_column.

      Emits a watermark of the maximum observed timestamp so far. Rows that have a timestamp smaller to the max timestamp are not late.

      • Ascending timestamps: WATERMARK FOR rowtime_column AS rowtime_column - INTERVAL '0.001' SECOND.
        Emits a watermark of the maximum observed timestamp so far minus 1. Rows that have a timestamp equal and smaller to the max timestamp are not late.

      [1] https://ci.apache.org/projects/flink/flink-docs-release-1.10/dev/table/sql/create.html

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                Leonard Xu Leonard Xu
                Reporter:
                Leonard Xu Leonard Xu
              • Votes:
                0 Vote for this issue
                Watchers:
                2 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: