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 " +
