HBASE-4400 fixed up the anonymous Abortable in createAndForceNodeToOpenedState()
git-svn-id: https://svn.apache.org/repos/asf/hbase/trunk@1172068 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
034215f247
commit
aa6d6c7a9e
|
@ -1578,10 +1578,16 @@ public class HBaseTestingUtility {
|
||||||
IOException, KeeperException, NodeExistsException {
|
IOException, KeeperException, NodeExistsException {
|
||||||
ZooKeeperWatcher zkw = new ZooKeeperWatcher(TEST_UTIL.getConfiguration(),
|
ZooKeeperWatcher zkw = new ZooKeeperWatcher(TEST_UTIL.getConfiguration(),
|
||||||
"unittest", new Abortable() {
|
"unittest", new Abortable() {
|
||||||
|
boolean aborted = false;
|
||||||
@Override
|
@Override
|
||||||
public void abort(String why, Throwable e) {
|
public void abort(String why, Throwable e) {
|
||||||
|
aborted = true;
|
||||||
throw new RuntimeException("Fatal ZK error, why=" + why, e);
|
throw new RuntimeException("Fatal ZK error, why=" + why, e);
|
||||||
}
|
}
|
||||||
|
@Override
|
||||||
|
public boolean isAborted() {
|
||||||
|
return aborted;
|
||||||
|
}
|
||||||
});
|
});
|
||||||
|
|
||||||
ZKAssign.createNodeOffline(zkw, region.getRegionInfo(), regionServer
|
ZKAssign.createNodeOffline(zkw, region.getRegionInfo(), regionServer
|
||||||
|
|
Loading…
Reference in New Issue