[jira] [Created] (FLINK-4773) Introduce an OperatorIOMetricGroup

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-4773) Introduce an OperatorIOMetricGroup

Shang Yuanchun (Jira)
Chesnay Schepler created FLINK-4773:
---------------------------------------

             Summary: Introduce an OperatorIOMetricGroup
                 Key: FLINK-4773
                 URL: https://issues.apache.org/jira/browse/FLINK-4773
             Project: Flink
          Issue Type: Improvement
          Components: Metrics
    Affects Versions: 1.1.2
            Reporter: Chesnay Schepler
            Assignee: Chesnay Schepler
             Fix For: 1.2.0


Task related IO metrics (numBytesIn/Out) are not instantiated directly by the task, but instead within the IOMetricGroup contained in the respective TaskMetricGroup. They are then later accessed by relevant components, instead of creating them themselves. This has the advantage that they can be accessed from several places, and that they are guaranteed to always be instantiated identically (without requiring static name constants).

I propose to do the same for operators.

This is also a prerequisite for FLINK-4733.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)