Andrey Zagrebin created FLINK-12202:
---------------------------------------
Summary: Consider introducing batch metric register in NetworkEnviroment
Key: FLINK-12202
URL:
https://issues.apache.org/jira/browse/FLINK-12202 Project: Flink
Issue Type: Sub-task
Reporter: Andrey Zagrebin
Assignee: zhijiang
As we have some network specific metrics registered in TaskIOMetricGroup (In/OutputBuffersGauge, In/OutputBufferPoolUsageGauge), we can introduce batch metric registering in NetworkEnviroment.registerMetrics(ProxyMetricGroup, partitions, gates), where task passes its TaskIOMetricGroup into ProxyMetricGroup. This way we could break a tie between task and NetworkEnviroment. TaskIOMetricGroup.initializeBufferMetrics, In/OutputBuffersGauge, In/OutputBufferPoolUsageGauge could be moved into NetworkEnviroment.registerMetrics and network code.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)