[ https://issues.apache.org/jira/browse/FLINK-5169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Ufuk Celebi closed FLINK-5169. ------------------------------ Resolution: Fixed Fixed in 6cfce17, 8d97eaa, 5ebd7c8, 2bf8722 (release-1.1) and f728129, d3ac0ad, c0cdc5c, 2fcef5e (master). > 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)