@AfterClass public static void cleanupTest() throws Exception { try { UTIL.shutdownMiniCluster(); } catch ( Exception e) { LOG.warn("failure shutting down cluster",e); } }