135136137138139140141142143144145
final CountDownLatch doneSignal = new CountDownLatch(1); Thread exitThread = new Thread() { @Override public void run() { try { miniCluster.stop(); } catch (Throwable e) { console.error("Error stopping mini cluster. Exiting anyways...", e); } doneSignal.countDown(); }