You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by kg...@apache.org on 2020/10/13 08:10:59 UTC
[hive] branch master updated: HIVE-24069: HiveHistory should log
the task that ends abnormally (#1429)
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 <de...@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)) {