diff --git ql/src/java/org/apache/hadoop/hive/ql/exec/FileSinkOperator.java ql/src/java/org/apache/hadoop/hive/ql/exec/FileSinkOperator.java index 082f1cbc09..1b84ba29a6 100644 --- ql/src/java/org/apache/hadoop/hive/ql/exec/FileSinkOperator.java +++ ql/src/java/org/apache/hadoop/hive/ql/exec/FileSinkOperator.java @@ -791,11 +791,6 @@ protected void createBucketFiles(FSPaths fsp) throws HiveException { filesIdx++; } assert filesIdx == numFiles; - - // in recent hadoop versions, use deleteOnExit to clean tmp files. - if (isNativeTable() && fs != null && fsp != null && !conf.isMmTable() && !conf.isDirectInsert()) { - autoDelete = fs.deleteOnExit(fsp.outPaths[0]); - } } catch (Exception e) { throw new HiveException(e); }