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

Add dynamic open/close LatencyMarksEmitter to support online debug and monitoring

    XMLWordPrintableJSON

    Details

    • Type: Improvement
    • Status: Open
    • Priority: Major
    • Resolution: Unresolved
    • Affects Version/s: None
    • Fix Version/s: None
    • Component/s: API / DataStream
    • Labels:
      None

      Description

      Now, flink has provided latency metrics to monitor the latency, but this function mainly used in debugging contexts rather than in production contexts because of throughput effect. If we provider an api that can dynamic open/close this function, then we can monitor the online data latency and find out the performance bottleneck in time without restart the job, which maybe helpful for online debug. 

        Attachments

          Activity

            People

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

              Dates

              • Created:
                Updated: