269270271272273274275276277278279
} finally { try { // creating the context can create a bunch of files. So make // sure to clear it out if(ctxCreated) { ctx.clear(); } } catch (Exception e) { LOG.error("Exception: " + e.getMessage()); }
209210211212213214215216217218219
success = false; returnVal = 1; } finally { try { if (ctxCreated) { ctx.clear(); } if (rj != null) { if (returnVal != 0) { rj.killJob(); }
240241242243244245246247248249250
233234235236237238239240241242243
306307308309310311312313314315316
447448449450451452453454455456457
returnVal = 1; } finally { Utilities.clearWork(job); try { if (ctxCreated) { ctx.clear(); } if (rj != null) { if (returnVal != 0) { rj.killJob();
206207208209210211212213214215216
274275276277278279280281282283284
431432433434435436437438439440441
returnVal = 1; } finally { Utilities.clearMapRedWork(job); try { if (ctxCreated) { ctx.clear(); } if (rj != null) { if (returnVal != 0) { rj.killJob();
179180181182183184185186187188189
// rc will be 1 at this point indicating failure. } finally { Utilities.clearWork(conf); if (cleanContext) { try { ctx.clear(); } catch (Exception e) { /*best effort*/ LOG.warn("Failed to clean up after tez job"); } }