incubator-hama-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From edwardy...@apache.org
Subject svn commit: r1221650 - /incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/GroomServer.java
Date Wed, 21 Dec 2011 09:00:40 GMT
Author: edwardyoon
Date: Wed Dec 21 09:00:39 2011
New Revision: 1221650

URL: http://svn.apache.org/viewvc?rev=1221650&view=rev
Log:
Trivial changes

Modified:
    incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/GroomServer.java

Modified: incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/GroomServer.java
URL: http://svn.apache.org/viewvc/incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/GroomServer.java?rev=1221650&r1=1221649&r2=1221650&view=diff
==============================================================================
--- incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/GroomServer.java (original)
+++ incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/GroomServer.java Wed Dec 21
09:00:39 2011
@@ -150,12 +150,12 @@ public class GroomServer implements Runn
         int prevPort = Constants.DEFAULT_PEER_PORT;
 
         for (GroomServerAction action : actions) {
-          Task t = ((LaunchTaskAction) action).getTask();
-
-          prevPort = BSPNetUtils.getNextAvailable(prevPort);
-          assignedPeerNames.put(t.getTaskID(), prevPort);
-          
           if (action instanceof LaunchTaskAction) {
+            Task t = ((LaunchTaskAction) action).getTask();
+
+            prevPort = BSPNetUtils.getNextAvailable(prevPort);
+            assignedPeerNames.put(t.getTaskID(), prevPort);
+
             startNewTask((LaunchTaskAction) action);
           } else {
 



Mime
View raw message