hama-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tjungb...@apache.org
Subject svn commit: r1350606 - /hama/trunk/core/src/main/java/org/apache/hama/bsp/sync/ZooKeeperSyncClientImpl.java
Date Fri, 15 Jun 2012 13:10:42 GMT
Author: tjungblut
Date: Fri Jun 15 13:10:41 2012
New Revision: 1350606

URL: http://svn.apache.org/viewvc?rev=1350606&view=rev
Log:
fixing syncing

Modified:
    hama/trunk/core/src/main/java/org/apache/hama/bsp/sync/ZooKeeperSyncClientImpl.java

Modified: hama/trunk/core/src/main/java/org/apache/hama/bsp/sync/ZooKeeperSyncClientImpl.java
URL: http://svn.apache.org/viewvc/hama/trunk/core/src/main/java/org/apache/hama/bsp/sync/ZooKeeperSyncClientImpl.java?rev=1350606&r1=1350605&r2=1350606&view=diff
==============================================================================
--- hama/trunk/core/src/main/java/org/apache/hama/bsp/sync/ZooKeeperSyncClientImpl.java (original)
+++ hama/trunk/core/src/main/java/org/apache/hama/bsp/sync/ZooKeeperSyncClientImpl.java Fri
Jun 15 13:10:41 2012
@@ -100,7 +100,8 @@ public class ZooKeeperSyncClientImpl imp
         final String pathToSuperstepZnode = pathToJobIdZnode + "/" + superstep;
         createZnode(pathToSuperstepZnode);
         BarrierWatcher barrierWatcher = new BarrierWatcher();
-
+        // this is really needed to register the barrier watcher, don't remove this line!
+        zk.exists(pathToSuperstepZnode + "/ready", barrierWatcher);
         zk.create(getNodeName(taskId, superstep), null, Ids.OPEN_ACL_UNSAFE,
             CreateMode.EPHEMERAL);
 



Mime
View raw message