flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "zhijiang (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-7456) Implement Netty sender incoming pipeline for credit-based
Date Wed, 16 Aug 2017 10:21:01 GMT
zhijiang created FLINK-7456:

             Summary: Implement Netty sender incoming pipeline for credit-based
                 Key: FLINK-7456
                 URL: https://issues.apache.org/jira/browse/FLINK-7456
             Project: Flink
          Issue Type: Sub-task
          Components: Network
            Reporter: zhijiang
             Fix For: 1.4.0

This is a part of work for credit-based network flow control.

On sender side, each subpartition view maintains an atomic integer `currentCredit` from receiver.
Once receiving the messages of `PartitionRequest` and `AddCredit`, the `currentCredit` is
added by deltas.

Each view also maintains an atomic boolean field to mark it as registered available for transfer
to make sure it is enqueued in handler only once. If the `currentCredit` increases from zero
and there are available buffers in the subpartition, the corresponding view will be enqueued
for transferring data.

This message was sent by Atlassian JIRA

View raw message