Mailing-List: contact issues-help@flink.apache.org; run by ezmlm
Precedence: bulk
Reply-To: dev@flink.apache.org
Date: Mon, 28 Nov 2016 10:51:59 +0000 (UTC)
From: "ASF GitHub Bot (JIRA)" <jira@apache.org>
To: issues@flink.apache.org
Message-ID: <JIRA.13023659.1480323045000.376689.1480330319792@Atlassian.JIRA>
In-Reply-To: <JIRA.13023659.1480323045000@Atlassian.JIRA>
References: <JIRA.13023659.1480323045000@Atlassian.JIRA> <JIRA.13023659.1480323045537@arcas>
Subject: [jira] [Commented] (FLINK-5169) Make consumption of input channels
 fair
MIME-Version: 1.0
Content-Type: text/plain; charset=utf-8
Content-Transfer-Encoding: 7bit
archived-at: Mon, 28 Nov 2016 10:52:01 -0000


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

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_r89757176
  
    --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/SingleInputGate.java ---
    @@ -495,6 +518,27 @@ void triggerPartitionStateCheck(ResultPartitionID partitionId) {
     				partitionId);
     	}
     
    +	private void queueChannel(InputChannel channel) {
    +		int availableChannels;
    +
    +		synchronized (inputChannelsWithData) {
    +			availableChannels = inputChannelsWithData.size();
    +
    +			inputChannelsWithData.add(channel);
    +
    +			if (availableChannels == 0) {
    +				inputChannelsWithData.notify();
    --- End diff --
    
    This should be a `notifyAll()`.


> 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)