You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by se...@apache.org on 2015/08/06 02:50:31 UTC
[25/53] [abbrv] hive git commit: HIVE-11380: NPE when
FileSinkOperator is not initialized (Yongzhi Chen, reviewed by Sergio Pena)
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/8b2cd2ab
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/8b2cd2ab
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/8b2cd2ab
Branch: refs/heads/llap
Commit: 8b2cd2abf2a32e42d24e60f1ac7a026af783dcbd
Parents: 2519915
Author: Sergio Pena <se...@cloudera.com>
Authored: Sun Aug 2 20:07:11 2015 -0500
Committer: Sergio Pena <se...@cloudera.com>
Committed: Sun Aug 2 20:07:11 2015 -0500
----------------------------------------------------------------------
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/8b2cd2ab/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 553113e..2604d5d 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) {