flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From zhijiangW <...@git.apache.org>
Subject [GitHub] flink pull request #5381: [FLINK-8523][network] Stop assigning floating buff...
Date Wed, 31 Jan 2018 09:04:07 GMT
Github user zhijiangW commented on a diff in the pull request:

    https://github.com/apache/flink/pull/5381#discussion_r164988413
  
    --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/SingleInputGate.java
---
    @@ -133,8 +134,13 @@
     	 * Input channels. There is a one input channel for each consumed intermediate result
partition.
     	 * We store this in a map for runtime updates of single channels.
     	 */
    +	@GuardedBy("requestLock")
     	private final Map<IntermediateResultPartitionID, InputChannel> inputChannels;
     
    +	/** A mapping from internal channel index in this gate to input channel. */
    +	@GuardedBy("requestLock")
    +	private final Map<Integer, InputChannel> indexToInputChannelMap;
    --- End diff --
    
    ok


---

Mime
View raw message