[
https://issues.apache.org/jira/browse/FLINK-22438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-22438:
-----------------------------------
Fix Version/s: (was: 1.12.3)
1.12.4
> add numRecordsOut metric for Async IO
> -------------------------------------
>
> Key: FLINK-22438
> URL: https://issues.apache.org/jira/browse/FLINK-22438
> Project: Flink
> Issue Type: Bug
> Components: Runtime / Metrics, Runtime / Task
> Affects Versions: 1.11.3, 1.12.2, 1.13.0
> Reporter: Zhengqi Zhang
> Assignee: Zhengqi Zhang
> Priority: Major
> Labels: pull-request-available
> Fix For: 1.14.0, 1.13.1, 1.12.4
>
> 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)
