in phoenix-queryserver-load-balancer/src/main/java/org/apache/phoenix/loadbalancer/service/LoadBalancer.java [57:74]
private LoadBalancer() {
try {
start();
}catch(Exception ex){
LOG.error("Exception while creating a zookeeper clients and cache",ex);
if ((curaFramework != null) && (connectionStateListener != null)){
curaFramework.getConnectionStateListenable()
.removeListener(connectionStateListener);
}
if ((curaFramework != null) && (unhandledErrorListener != null)){
curaFramework.getUnhandledErrorListenable()
.removeListener(unhandledErrorListener);
}
for (Closeable closeable : closeAbles) {
CloseableUtils.closeQuietly(closeable);
}
}
}