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

              leonard Leonard Xu
              leonard Leonard Xu
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: