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 <[email protected]> Authored: Sun Aug 2 20:07:11 2015 -0500 Committer: Sergio Pena <[email protected]> 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) {
