You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hama.apache.org by ke...@apache.org on 2013/07/13 05:05:38 UTC
svn commit: r1502739 - in /hama/trunk: CHANGES.txt
core/src/main/java/org/apache/hama/bsp/message/AbstractMessageManager.java
Author: kennethxian
Date: Sat Jul 13 03:05:36 2013
New Revision: 1502739
URL: http://svn.apache.org/r1502739
Log:
HAMA-776: localQueue is set as Send queue in init function of AbstractMessageManager
Modified:
hama/trunk/CHANGES.txt
hama/trunk/core/src/main/java/org/apache/hama/bsp/message/AbstractMessageManager.java
Modified: hama/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/hama/trunk/CHANGES.txt?rev=1502739&r1=1502738&r2=1502739&view=diff
==============================================================================
--- hama/trunk/CHANGES.txt (original)
+++ hama/trunk/CHANGES.txt Sat Jul 13 03:05:36 2013
@@ -6,6 +6,7 @@ Release 0.6.3 (unreleased changes)
BUG FIXES
+ HAMA-776: localQueue is set as Send queue in init function of AbstractMessageManager (kennethxian)
HAMA-769: Intermediate queue's close method is not called, clean work may be omitted (kennethxian)
HAMA-771: Determining the count of active vertices (edwardyoon)
HAMA-777: FunctionFactory does not work when create IdentityFunction (Yexi Jiang)
Modified: hama/trunk/core/src/main/java/org/apache/hama/bsp/message/AbstractMessageManager.java
URL: http://svn.apache.org/viewvc/hama/trunk/core/src/main/java/org/apache/hama/bsp/message/AbstractMessageManager.java?rev=1502739&r1=1502738&r2=1502739&view=diff
==============================================================================
--- hama/trunk/core/src/main/java/org/apache/hama/bsp/message/AbstractMessageManager.java (original)
+++ hama/trunk/core/src/main/java/org/apache/hama/bsp/message/AbstractMessageManager.java Sat Jul 13 03:05:36 2013
@@ -90,7 +90,7 @@ public abstract class AbstractMessageMan
this.peer = peer;
this.conf = conf;
this.peerAddress = peerAddress;
- this.localQueue = getSenderQueue();
+ this.localQueue = getReceiverQueue();
this.localQueueForNextIteration = getSynchronizedReceiverQueue();
this.maxCachedConnections = conf.getInt(MAX_CACHED_CONNECTIONS_KEY, 100);
}