You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "zhijiang (JIRA)" <ji...@apache.org> on 2019/06/04 10:27:00 UTC

[jira] [Commented] (FLINK-12201) Introduce InputGateWithMetrics in Task to increment numBytesIn metric

    [ https://issues.apache.org/jira/browse/FLINK-12201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16855554#comment-16855554 ] 

zhijiang commented on FLINK-12201:
----------------------------------

master : 3351ca11a366713328a6d0cb0e87100cb8c24200

> 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: 20m
>  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)