hama-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From edwardy...@apache.org
Subject svn commit: r1202531 - /incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/sync/ZooKeeperSyncClientImpl.java
Date Wed, 16 Nov 2011 05:21:08 GMT
Author: edwardyoon
Date: Wed Nov 16 05:21:07 2011
New Revision: 1202531

URL: http://svn.apache.org/viewvc?rev=1202531&view=rev
Log:
My miscommit

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

Modified: incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/sync/ZooKeeperSyncClientImpl.java
URL: http://svn.apache.org/viewvc/incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/sync/ZooKeeperSyncClientImpl.java?rev=1202531&r1=1202530&r2=1202531&view=diff
==============================================================================
--- incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/sync/ZooKeeperSyncClientImpl.java
(original)
+++ incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/sync/ZooKeeperSyncClientImpl.java
Wed Nov 16 05:21:07 2011
@@ -99,6 +99,8 @@ public class ZooKeeperSyncClientImpl imp
       createZnode(pathToSuperstepZnode);
       BarrierWatcher barrierWatcher = new BarrierWatcher();
 
+      Stat readyStat = zk.exists(pathToSuperstepZnode + "/ready",
+          barrierWatcher);
       zk.create(getNodeName(taskId, superstep), null, Ids.OPEN_ACL_UNSAFE,
           CreateMode.EPHEMERAL);
 



Mime
View raw message