277278279280281282283284285286287
if (tries == maxTries - 1 ) { throw new IOException(e); } } finally { try { zk.shutdown(); } catch (InterruptedException ie) { if (tries == maxTries - 1) { throw new IOException(ie); } }
598599600601602603604605606607608
throw new IOException("writeLastTxidToZookeeper() interrupted", ie); } } } finally { try { zk.shutdown(); } catch (InterruptedException ie) { throw new IOException(ie); } } }
661662663664665666667668669670671
+ " does not match the session Id in the txid node : " + zkTxId.getSessionId()); } return zkTxId; } finally { zk.shutdown(); } } catch (Exception e) { throw new IOException(e); } }
715716717718719720721722723724725
// Register rpc address registerAddressToZK(zk, AvatarNode.DFS_NAMENODE_RPC_ADDRESS_KEY); } finally { try { zk.shutdown(); } catch (InterruptedException e) { throw new IOException("Could not shutdown zk client", e); } } }
15081509151015111512151315141515151615171518
+ "from ZooKeeper. Aborting the start", e); zkRegistryMatch = false; } finally { try { zk.shutdown(); } catch (InterruptedException e) { LOG.error("Error shutting down ZooKeeper client", e); } } if (!zkRegistryMatch && !startInfo.isStandby) {
15821583158415851586158715881589159015911592
LOG.error("Got Exception reading primary node registration " + "from ZooKeeper.", e); throw e; } finally { try { zk.shutdown(); } catch (InterruptedException e) { LOG.error("Error shutting down ZooKeeper client", e); } } }