Details
-
Sub-task
-
Status: Closed
-
Major
-
Resolution: Fixed
-
None
Description
At the moment we have numBytesInLocal/numBytesInRemote in IOMetrics but in the actual usage we just always sum them up. As local/remote is the detail of shuffle service implementation, we can merge the local/remote metrics into one and increment it later in Task instead of remote/local channels in network internals.
Attachments
Issue Links
- is depended upon by
-
FLINK-12201 Introduce InputGateWithMetrics in Task to increment numBytesIn metric
- Closed
-
FLINK-11726 Refactor the creation of ResultPartition and InputGate into NetworkEnvironment
- Closed
- links to