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)
