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

add numRecordsOut metric for Async IO

Attach filesAttach ScreenshotVotersWatch issueWatchersCreate sub-taskLinkCloneUpdate Comment AuthorReplace String in CommentUpdate Comment VisibilityDelete Comments
    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

        Issue Links

          Activity

            People

            • Assignee:
              Tony Giao Zhengqi Zhang
              Reporter:
              Tony Giao Zhengqi Zhang

              Dates

              • Created:
                Updated:
                Resolved:

                Time Tracking

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

                  Issue deployment