Author: aching
Date: Sat Oct  1 18:25:37 2011
New Revision: 1178065

URL: http://svn.apache.org/viewvc?rev=1178065&view=rev
Log:
GIRAPH-46: Race condition on superstep 1 with RPC servers not started
by the time that requests are sent. (aching)


Modified:
    incubator/giraph/trunk/CHANGELOG
    
incubator/giraph/trunk/src/main/java/org/apache/giraph/graph/GraphMapper.java

Modified: incubator/giraph/trunk/CHANGELOG
URL: 
http://svn.apache.org/viewvc/incubator/giraph/trunk/CHANGELOG?rev=1178065&r1=1178064&r2=1178065&view=diff
==============================================================================
--- incubator/giraph/trunk/CHANGELOG (original)
+++ incubator/giraph/trunk/CHANGELOG Sat Oct  1 18:25:37 2011
@@ -2,6 +2,9 @@ Giraph Change Log
 
 Release 0.70.0 - unreleased
 
+  GIRAPH-46: Race condition on superstep 1 with RPC servers not
+  started by the time that requests are sent. (aching)
+
   GIRAPH-21: Revise CODE_CONVENTIONS. (aching via jghoman)
 
   GIRAPH-39: mvn rat doesn't like .git or .idea. (jghoman)

Modified: 
incubator/giraph/trunk/src/main/java/org/apache/giraph/graph/GraphMapper.java
URL: 
http://svn.apache.org/viewvc/incubator/giraph/trunk/src/main/java/org/apache/giraph/graph/GraphMapper.java?rev=1178065&r1=1178064&r2=1178065&view=diff
==============================================================================
--- 
incubator/giraph/trunk/src/main/java/org/apache/giraph/graph/GraphMapper.java 
(original)
+++ 
incubator/giraph/trunk/src/main/java/org/apache/giraph/graph/GraphMapper.java 
Sat Oct  1 18:25:37 2011
@@ -562,7 +562,7 @@ public class GraphMapper<I extends Writa
                           " maxMem=" + Runtime.getRuntime().maxMemory() +
                           " freeMem=" + Runtime.getRuntime().freeMemory());
             }
-            if ((superstep > BspService.INPUT_SUPERSTEP) &&
+            if ((superstep >= BspService.INPUT_SUPERSTEP) &&
                     (commService == null)) {
                 if (LOG.isInfoEnabled()) {
                     LOG.info("map: Starting communication service on " +


Reply via email to