diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezTask.java b/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezTask.java index a2060da..2882d20 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezTask.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezTask.java @@ -236,13 +236,18 @@ public int execute(DriverContext driverContext) { ctx.clear(); } catch (Exception e) { /*best effort*/ - LOG.warn("Failed to clean up after tez job"); + LOG.warn("Failed to clean up after tez job", e); } } // need to either move tmp files or remove them if (dagClient != null) { // rc will only be overwritten if close errors out rc = close(work, rc); + try { + dagClient.close(); + } catch (Exception e) { + LOG.warn("Failed to close DagClient", e); + } } } return rc;