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

TimestampExtractor Does not Work When returning Long.MIN_VALUE

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Closed
    • Major
    • Resolution: Fixed
    • 0.10.0
    • 0.10.1, 1.0.0
    • None
    • None

    Description

      The problem is that ExtractTimestampsOperator wrongly updates the currentWatermark in the trigger method. This will interfere with values returned from extractWatermark.

      Attachments

        Activity

          People

            aljoscha Aljoscha Krettek
            aljoscha Aljoscha Krettek
            Votes:
            0 Vote for this issue
            Watchers:
            1 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: