svn commit: r1350606 - /hama/trunk/core/src/main/java/org/apache/hama/bsp/sync/ZooKeeperSyncClientImpl.java

[tjungblut]

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);