diff --git ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezJobExecHelper.java ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezJobExecHelper.java index a544b93..bc9bef4 100644 --- ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezJobExecHelper.java +++ ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezJobExecHelper.java @@ -44,7 +44,7 @@ public static void killRunningJobs() { } catch (Exception e) { // It is not available do nothing - LOG.debug("Could not stop tez dags: ", e); + LOG.error("Could not stop tez dags: ", e); } } } diff --git ql/src/java/org/apache/hadoop/hive/ql/exec/tez/monitoring/TezJobMonitor.java ql/src/java/org/apache/hadoop/hive/ql/exec/tez/monitoring/TezJobMonitor.java index 1e54f6e..c0a068d 100644 --- ql/src/java/org/apache/hadoop/hive/ql/exec/tez/monitoring/TezJobMonitor.java +++ ql/src/java/org/apache/hadoop/hive/ql/exec/tez/monitoring/TezJobMonitor.java @@ -300,8 +300,11 @@ private static boolean hasInterruptedException(Throwable e) { /** * killRunningJobs tries to terminate execution of all * currently running tez queries. No guarantees, best effort only. + * + * {@link org.apache.hadoop.hive.ql.exec.tez.TezJobExecHelper#killRunningJobs()} makes use of + * this method via reflection. */ - private static void killRunningJobs() { + public static void killRunningJobs() { synchronized (shutdownList) { for (DAGClient c : shutdownList) { try {