You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by se...@apache.org on 2014/11/13 17:16:03 UTC
incubator-flink git commit: Fix caching of receivers
Repository: incubator-flink
Updated Branches:
refs/heads/master d332d6c31 -> 8f9d8ea9c
Fix caching of receivers
Project: http://git-wip-us.apache.org/repos/asf/incubator-flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-flink/commit/8f9d8ea9
Tree: http://git-wip-us.apache.org/repos/asf/incubator-flink/tree/8f9d8ea9
Diff: http://git-wip-us.apache.org/repos/asf/incubator-flink/diff/8f9d8ea9
Branch: refs/heads/master
Commit: 8f9d8ea9c0039e47bb4a82ce712c04d41e110fe6
Parents: d332d6c
Author: Stephan Ewen <se...@apache.org>
Authored: Thu Nov 13 16:29:48 2014 +0100
Committer: Stephan Ewen <se...@apache.org>
Committed: Thu Nov 13 17:10:19 2014 +0100
----------------------------------------------------------------------
.../java/org/apache/flink/runtime/io/network/ChannelManager.java | 4 +---
1 file changed, 1 insertion(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/8f9d8ea9/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/ChannelManager.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/ChannelManager.java b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/ChannelManager.java
index 5f302e3..0419231 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/ChannelManager.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/ChannelManager.java
@@ -396,9 +396,7 @@ public class ChannelManager implements EnvelopeDispatcher, BufferProviderBroker
}
}
- if (channels.containsKey(sourceChannelID)) {
- this.receiverCache.put(sourceChannelID, receiverList);
- }
+ this.receiverCache.put(sourceChannelID, receiverList);
if (LOG.isDebugEnabled()) {
LOG.debug(String.format("Receiver for %s: %s [%s])",