[hive] branch master updated: HIVE-25561: Killed task should not commit file. (#2674) (zhengchenyu reviewed by Zoltan Haindrich)

[kgyrtkirk]

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 63bb7b9  HIVE-25561: Killed task should not commit file. (#2674) 
(zhengchenyu reviewed by Zoltan Haindrich)
63bb7b9 is described below

commit 63bb7b922cd5693ecdfc49859d905259625f01b2
Author: zhengchenyu <zhengcheny...@gmail.com>
AuthorDate: Fri Nov 26 15:35:30 2021 +0800

    HIVE-25561: Killed task should not commit file. (#2674) (zhengchenyu 
reviewed by Zoltan Haindrich)
    
    Co-authored-by: zhengchenyu001 <zhengchenyu...@ke.com>
---
 ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezProcessor.java | 1 +
 1 file changed, 1 insertion(+)

diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezProcessor.java 
b/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezProcessor.java
index 2a4dcfb..0cbcc26 100644
--- a/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezProcessor.java
+++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezProcessor.java
@@ -312,6 +312,7 @@ public class TezProcessor extends 
AbstractLogicalIOProcessor {
 
       perfLogger.perfLogEnd(CLASS_NAME, PerfLogger.TEZ_RUN_PROCESSOR);
     } catch (Throwable t) {
+      rproc.setAborted(true);
       originalThrowable = t;
     } finally {
       if (originalThrowable != null && (originalThrowable instanceof Error ||