flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "zhijiang (JIRA)" <j...@apache.org>
Subject [jira] [Updated] (FLINK-12201) Introduce InputGateWithMetrics in Task to increment numBytesIn metric
Date Fri, 24 May 2019 09:02:00 GMT

     [ https://issues.apache.org/jira/browse/FLINK-12201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]

zhijiang updated FLINK-12201:
-----------------------------
    Description: Incrementing of numBytesIn metric in SingleInputGate 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 numBytesIn metric.
 (was: 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.)

> Introduce InputGateWithMetrics in Task to increment numBytesIn metric
> ---------------------------------------------------------------------
>
>                 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
>            Priority: Major
>              Labels: pull-request-available
>             Fix For: 1.9.0
>
>          Time Spent: 10m
>  Remaining Estimate: 0h
>
> Incrementing of numBytesIn metric in SingleInputGate 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 numBytesIn metric.



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

Mime
View raw message