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

Report Watermark metrics in all operators

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Closed
    • Blocker
    • Resolution: Duplicate
    • 1.3.2, 1.4.0
    • None
    • API / DataStream, Runtime / Metrics
    • None

    Description

      Currently, the "currentLowWatermark" metric is only reported in StreamInputProcessor (and the two-input version). This means that watermarks are only reported for operators directly after a shuffle.

      We should report the watermark in all operators (including sources), so that users can better diagnose problems with watermarks.

      Attachments

        Issue Links

          duplicates

          Improvement - An improvement or enhancement to an existing feature or task. FLINK-4812 Report Watermark metrics in all operators

          • Critical - Crashes, loss of data, severe memory leak.
          • Closed

          Activity

            People

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

              Dates

                Created:
                Updated:
                Resolved: