You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@giraph.apache.org by ac...@apache.org on 2011/12/21 19:37:20 UTC
svn commit: r1221836 - in /incubator/giraph/trunk: CHANGELOG
src/main/java/org/apache/giraph/comm/BasicRPCCommunications.java
Author: aching
Date: Wed Dec 21 18:37:20 2011
New Revision: 1221836
URL: http://svn.apache.org/viewvc?rev=1221836&view=rev
Log:
GIRAPH-114: Inconsistent message map handling in
BasicRPCCommunications.LargeMessageFlushExecutor. (ssc via aching)
Modified:
incubator/giraph/trunk/CHANGELOG
incubator/giraph/trunk/src/main/java/org/apache/giraph/comm/BasicRPCCommunications.java
Modified: incubator/giraph/trunk/CHANGELOG
URL: http://svn.apache.org/viewvc/incubator/giraph/trunk/CHANGELOG?rev=1221836&r1=1221835&r2=1221836&view=diff
==============================================================================
--- incubator/giraph/trunk/CHANGELOG (original)
+++ incubator/giraph/trunk/CHANGELOG Wed Dec 21 18:37:20 2011
@@ -2,6 +2,9 @@ Giraph Change Log
Release 0.70.0 - unreleased
+ GIRAPH-114: Inconsistent message map handling in
+ BasicRPCCommunications.LargeMessageFlushExecutor. (ssc via aching)
+
GIRAPH-109: GiraphRunner should provide support for combiners.
(ssc via claudio)
Modified: incubator/giraph/trunk/src/main/java/org/apache/giraph/comm/BasicRPCCommunications.java
URL: http://svn.apache.org/viewvc/incubator/giraph/trunk/src/main/java/org/apache/giraph/comm/BasicRPCCommunications.java?rev=1221836&r1=1221835&r2=1221836&view=diff
==============================================================================
--- incubator/giraph/trunk/src/main/java/org/apache/giraph/comm/BasicRPCCommunications.java (original)
+++ incubator/giraph/trunk/src/main/java/org/apache/giraph/comm/BasicRPCCommunications.java Wed Dec 21 18:37:20 2011
@@ -336,8 +336,7 @@ public abstract class BasicRPCCommunicat
this.destVertex = destVertex;
outMessageList =
peerConnection.outMessagesPerPeer.get(destVertex);
- peerConnection.outMessagesPerPeer.put(destVertex,
- new MsgList<M>());
+ peerConnection.outMessagesPerPeer.remove(destVertex);
}
}