Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-33681 Display source/sink numRecordsIn/Out & numBytesIn/Out on UI
  3. FLINK-33682

Reuse source operator input records/bytes metrics for SourceOperatorStreamTask

    XMLWordPrintableJSON

Details

    Description

      For SourceOperatorStreamTask, source opeartor is the head operator that takes input. We can directly reuse source operator input records/bytes metrics for it.

      Attachments

        Issue Links

          Activity

            People

              Zhanghao Chen Zhanghao Chen
              Zhanghao Chen Zhanghao Chen
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: