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

Add support for ignore abnormal watermark

    XMLWordPrintableJSON

    Details

      Description

      When using eventTime and extract watermark from element timestamp to generate BoundedOutOfOrderness waternark, if one of the element timestamp is abnormal(assume the timestamp is very big, for example Integer.MAX_VALUE), then the watermark became very big too, and then the normal element timestamp can not trigger the window bellow any more. I think maybe there can provide a option to just ignore the abnormal element timestamp or generate a normal watermark base on the current processTime.

        Attachments

          Activity

            People

            • Assignee:
              Unassigned
              Reporter:
              zlzhang0122 zlzhang0122
            • Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

              • Created:
                Updated: