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)
