[jira] [Created] (FLINK-22438) add numRecordsOut metric for Async IO

[Shang Yuanchun (Jira)]

Zhengqi Zhang created FLINK-22438:
-------------------------------------

             Summary: add numRecordsOut metric for Async IO
                 Key: FLINK-22438
                 URL: https://issues.apache.org/jira/browse/FLINK-22438
             Project: Flink
          Issue Type: Improvement
          Components: Runtime / Metrics
    Affects Versions: 1.12.2
            Reporter: Zhengqi Zhang
         Attachments: QQ截图20210424004201.png

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|https://github.com/onyourhead/flink/commit/58a8ac27b292280696639caa2e311637cd631a00]



--
This message was sent by Atlassian Jira
(v8.3.4#803005)