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 553113e9aae0fb7224a0a9473c4c91df7afc2e70..2604d5d82fd5b4b67e6c7cb048c9840c4837d4b2 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 @@ protected void createBucketFiles(FSPaths fsp) throws HiveException { 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) {