[
https://issues.apache.org/jira/browse/FLINK-5169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15702944#comment-15702944
]
ASF GitHub Bot commented on FLINK-5169:
---------------------------------------
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2882#discussion_r89810526
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/PartitionRequestServerHandler.java
---
@@ -53,10 +52,10 @@
private BufferPool bufferPool;
PartitionRequestServerHandler(
- ResultPartitionProvider partitionProvider,
- TaskEventDispatcher taskEventDispatcher,
- PartitionRequestQueue outboundQueue,
- NetworkBufferPool networkBufferPool) {
--- End diff --
I think this formatting change made the readability a little bit worse.
> Make consumption of input channels fair
> ---------------------------------------
>
> Key: FLINK-5169
> URL: https://issues.apache.org/jira/browse/FLINK-5169
> Project: Flink
> Issue Type: Improvement
> Components: Network
> Reporter: Ufuk Celebi
> Assignee: Ufuk Celebi
> Priority: Critical
> Fix For: 1.2.0, 1.1.4
>
>
> The input channels on the receiver side of the network stack queue incoming
> data and notify the input gate about available data. These notifications
> currently determine the order in which input channels are consumed, which can
> lead to unfair consumption patterns where faster channels are favored over
> slower ones.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
