You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@accumulo.apache.org by kt...@apache.org on 2011/10/07 23:49:33 UTC
svn commit: r1180256 - in /incubator/accumulo:
branches/1.3/src/server/src/main/java/org/apache/accumulo/server/master/LiveTServerSet.java
trunk/src/server/src/main/java/org/apache/accumulo/server/master/LiveTServerSet.java
Author: kturner
Date: Fri Oct 7 21:49:32 2011
New Revision: 1180256
URL: http://svn.apache.org/viewvc?rev=1180256&view=rev
Log:
ACCUMULO-16 Use correct path when deleting tserver lock in zookeeper
Modified:
incubator/accumulo/branches/1.3/src/server/src/main/java/org/apache/accumulo/server/master/LiveTServerSet.java
incubator/accumulo/trunk/src/server/src/main/java/org/apache/accumulo/server/master/LiveTServerSet.java
Modified: incubator/accumulo/branches/1.3/src/server/src/main/java/org/apache/accumulo/server/master/LiveTServerSet.java
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.3/src/server/src/main/java/org/apache/accumulo/server/master/LiveTServerSet.java?rev=1180256&r1=1180255&r2=1180256&view=diff
==============================================================================
--- incubator/accumulo/branches/1.3/src/server/src/main/java/org/apache/accumulo/server/master/LiveTServerSet.java (original)
+++ incubator/accumulo/branches/1.3/src/server/src/main/java/org/apache/accumulo/server/master/LiveTServerSet.java Fri Oct 7 21:49:32 2011
@@ -261,7 +261,7 @@ public class LiveTServerSet implements W
if (remove != null) {
try {
remove.cleanup();
- ZooUtil.recursiveDelete(ZooUtil.getRoot(instance) + Constants.ZTSERVERS + "/" + server, SKIP);
+ ZooUtil.recursiveDelete(ZooUtil.getRoot(instance) + Constants.ZTSERVERS + "/" + server.hostPort(), SKIP);
} catch (Exception e) {
log.error("error removing tablet server lock", e);
}
Modified: incubator/accumulo/trunk/src/server/src/main/java/org/apache/accumulo/server/master/LiveTServerSet.java
URL: http://svn.apache.org/viewvc/incubator/accumulo/trunk/src/server/src/main/java/org/apache/accumulo/server/master/LiveTServerSet.java?rev=1180256&r1=1180255&r2=1180256&view=diff
==============================================================================
--- incubator/accumulo/trunk/src/server/src/main/java/org/apache/accumulo/server/master/LiveTServerSet.java (original)
+++ incubator/accumulo/trunk/src/server/src/main/java/org/apache/accumulo/server/master/LiveTServerSet.java Fri Oct 7 21:49:32 2011
@@ -282,7 +282,7 @@ public class LiveTServerSet implements W
}
}
log.info("Removing zookeeper lock for " + server);
- String zpath = ZooUtil.getRoot(instance) + Constants.ZTSERVERS + "/" + server;
+ String zpath = ZooUtil.getRoot(instance) + Constants.ZTSERVERS + "/" + server.hostPort();
try {
ZooReaderWriter.getInstance().recursiveDelete(zpath, SKIP);
} catch (Exception e) {