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

zhijiang updated FLINK-15021:
-----------------------------
    Description: After removing the non credit-based flow control codes, the 
channel writability changed logic in PartitionRequestQueue along with the 
setting of channel watermark are both invalid. Therefore we can remove them 
completely to simplify the codes.  (was: After removing the non credit-based 
flow control codes, the related channel writability changed logics in 
PartitionRequestQueue are invalid and can be removed completely. Therefore we 
can refactor the process to simplify the codes.)

> Remove setting of netty channel watermark and logic of writability changed
> --------------------------------------------------------------------------
>
>                 Key: FLINK-15021
>                 URL: https://issues.apache.org/jira/browse/FLINK-15021
>             Project: Flink
>          Issue Type: Task
>          Components: Runtime / Network
>            Reporter: zhijiang
>            Assignee: zhijiang
>            Priority: Minor
>              Labels: pull-request-available
>          Time Spent: 10m
>  Remaining Estimate: 0h
>
> After removing the non credit-based flow control codes, the channel 
> writability changed logic in PartitionRequestQueue along with the setting of 
> channel watermark are both invalid. Therefore we can remove them completely 
> to simplify the codes.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to