[jira] [Created] (FLINK-12201) Introduce InputGateWithMetrics in Task to increment in/out byte metrics

[Shang Yuanchun (Jira)]

Andrey Zagrebin created FLINK-12201:
---------------------------------------

             Summary: Introduce InputGateWithMetrics in Task to increment in/out byte metrics
                 Key: FLINK-12201
                 URL: https://issues.apache.org/jira/browse/FLINK-12201
             Project: Flink
          Issue Type: Sub-task
          Components: Runtime / Network
            Reporter: Andrey Zagrebin
            Assignee: zhijiang
             Fix For: 1.9.0


Incrementing of in/out byte metrics in local/remote input channel does not depend on shuffle service and can be moved out of network internals into Task. Task could wrap InputGate provided by ShuffleService with InputGateWithMetrics which would increment in/out byte metrics.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)