This is an automated email from the ASF dual-hosted git repository. kgyrtkirk pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/hive.git
The following commit(s) were added to refs/heads/master by this push: new d9588c9 HIVE-24069: HiveHistory should log the task that ends abnormally (#1429) d9588c9 is described below commit d9588c9731806a381f3358ea7e53bb0050c504fc Author: dengzh <dengzhhu...@gmail.com> AuthorDate: Tue Oct 13 16:10:47 2020 +0800 HIVE-24069: HiveHistory should log the task that ends abnormally (#1429) --- ql/src/java/org/apache/hadoop/hive/ql/Executor.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/ql/src/java/org/apache/hadoop/hive/ql/Executor.java b/ql/src/java/org/apache/hadoop/hive/ql/Executor.java index 3aba618..ce47d17 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/Executor.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/Executor.java @@ -274,6 +274,10 @@ public class Executor { TaskResult result = taskRun.getTaskResult(); int exitVal = result.getExitVal(); + SessionState.get().getHiveHistory().setTaskProperty(driverContext.getQueryId(), task.getId(), + Keys.TASK_RET_CODE, String.valueOf(exitVal)); + SessionState.get().getHiveHistory().endTask(driverContext.getQueryId(), task); + DriverUtils.checkInterrupted(driverState, driverContext, "when checking the execution result.", hookContext, SessionState.getPerfLogger()); @@ -284,10 +288,6 @@ public class Executor { taskQueue.finished(taskRun); - SessionState.get().getHiveHistory().setTaskProperty(driverContext.getQueryId(), task.getId(), - Keys.TASK_RET_CODE, String.valueOf(exitVal)); - SessionState.get().getHiveHistory().endTask(driverContext.getQueryId(), task); - if (task.getChildTasks() != null) { for (Task<?> child : task.getChildTasks()) { if (TaskQueue.isLaunchable(child)) {