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

add numRecordsOut metric for Async IO

    XMLWordPrintableJSON

    Details

      Description

      In Flink WebUI,there is no numRecordsOut metric,and the class AsyncWaitOperator did't have this metric in fact.Other operators have this metric, which makes it difficult to monitor Async IO operator and can cause confusion for users.

      I think we can directly  use the wrapping output class CountingOutput to update numRecordsOut metric.CountingOutput is used in super class of AsyncWaitOperator(AbstractStreamOperator).

      Here is my commit,And I have run a test, it work.

      my  commit

        Attachments

        1. QQ截图20210424004201.png
          42 kB
          Zhengqi Zhang

          Issue Links

            Activity

              People

              • Assignee:
                Tony Giao Zhengqi Zhang
                Reporter:
                Tony Giao Zhengqi Zhang
              • Votes:
                0 Vote for this issue
                Watchers:
                3 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved:

                  Time Tracking

                  Estimated:
                  Original Estimate - 24h
                  24h
                  Remaining:
                  Remaining Estimate - 24h
                  24h
                  Logged:
                  Time Spent - Not Specified
                  Not Specified