You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hama.apache.org by ed...@apache.org on 2011/09/23 08:06:27 UTC
svn commit: r1174534 -
/incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/BSPMaster.java
Author: edwardyoon
Date: Fri Sep 23 06:06:27 2011
New Revision: 1174534
URL: http://svn.apache.org/viewvc?rev=1174534&view=rev
Log:
Trivial changes
Modified:
incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/BSPMaster.java
Modified: incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/BSPMaster.java
URL: http://svn.apache.org/viewvc/incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/BSPMaster.java?rev=1174534&r1=1174533&r2=1174534&view=diff
==============================================================================
--- incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/BSPMaster.java (original)
+++ incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/BSPMaster.java Fri Sep 23 06:06:27 2011
@@ -484,6 +484,9 @@ public class BSPMaster implements JobSub
try {
for (String node : zk.getChildren(bspRoot, this)) {
for (String subnode : zk.getChildren(bspRoot + "/" + node, this)) {
+ for (String subnode2 : zk.getChildren(bspRoot + "/" + node, this)) {
+ zk.delete(bspRoot + "/" + node + "/" + subnode + "/" + subnode2, 0);
+ }
zk.delete(bspRoot + "/" + node + "/" + subnode, 0);
}
zk.delete(bspRoot + "/" + node, 0);