hive-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sp...@apache.org
Subject hive git commit: HIVE-11380: NPE when FileSinkOperator is not initialized (Yongzhi Chen, reviewed by Sergio Pena)
Date Thu, 12 Nov 2015 16:47:16 GMT
Repository: hive
Updated Branches:
  refs/heads/branch-1 edaae1f13 -> 859d5ddab


HIVE-11380: NPE when FileSinkOperator is not initialized (Yongzhi Chen, reviewed by Sergio
Pena)


Project: http://git-wip-us.apache.org/repos/asf/hive/repo
Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/859d5dda
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/859d5dda
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/859d5dda

Branch: refs/heads/branch-1
Commit: 859d5ddabdbbd8cd7a41b4ee1dc9df576f2fb106
Parents: edaae1f
Author: Sergio Pena <sergio.pena@cloudera.com>
Authored: Sun Aug 2 20:07:11 2015 -0500
Committer: Sergio Pena <sergio.pena@cloudera.com>
Committed: Thu Nov 12 10:46:43 2015 -0600

----------------------------------------------------------------------
 ql/src/java/org/apache/hadoop/hive/ql/exec/FileSinkOperator.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hive/blob/859d5dda/ql/src/java/org/apache/hadoop/hive/ql/exec/FileSinkOperator.java
----------------------------------------------------------------------
diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/FileSinkOperator.java b/ql/src/java/org/apache/hadoop/hive/ql/exec/FileSinkOperator.java
index ed791c0..d74c971 100644
--- a/ql/src/java/org/apache/hadoop/hive/ql/exec/FileSinkOperator.java
+++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/FileSinkOperator.java
@@ -569,7 +569,7 @@ public class FileSinkOperator extends TerminalOperator<FileSinkDesc>
implements
       assert filesIdx == numFiles;
 
       // in recent hadoop versions, use deleteOnExit to clean tmp files.
-      if (isNativeTable) {
+      if (isNativeTable && fs != null && fsp != null) {
         autoDelete = fs.deleteOnExit(fsp.outPaths[0]);
       }
     } catch (Exception e) {


Mime
View raw message