diff --git a/ql/src/java/org/apache/hadoop/hive/ql/Driver.java b/ql/src/java/org/apache/hadoop/hive/ql/Driver.java index 9f4e6f2e53..5dbe1561c0 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/Driver.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/Driver.java @@ -2177,6 +2177,9 @@ private void execute() throws CommandProcessorResponse { if (exitVal != 0) { Task backupTask = tsk.getAndInitBackupTask(); + if(backupTask == null && !tsk.getParentTasks().isEmpty()){ + backupTask = tsk.getParentTasks().get(0).getAndInitBackupTask(); + } if (backupTask != null) { setErrorMsgAndDetail(exitVal, result.getTaskError(), tsk); console.printError(errorMessage);