[
https://issues.apache.org/jira/browse/FLINK-22438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17331911#comment-17331911
]
Konstantin Knauf commented on FLINK-22438:
------------------------------------------
[~Tony Giao] Thank you for opening this ticket. I would actually consider this
is bug. You're solution looks good at first glance, but I am not too familiar
with the code.
[~chesnay] Could you quickly confirm that it is indeed such an easy?
> 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
> Priority: Major
> Attachments: QQ截图20210424004201.png
>
> Original Estimate: 24h
> Remaining Estimate: 24h
>
> 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)
