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 d0f452b0c7..b00bfd280c 100644 --- ql/src/java/org/apache/hadoop/hive/ql/exec/FileSinkOperator.java +++ ql/src/java/org/apache/hadoop/hive/ql/exec/FileSinkOperator.java @@ -1336,7 +1336,7 @@ public void closeOp(boolean abort) throws HiveException { Class clazz = conf.getTableInfo().getOutputFileFormatClass(); boolean isStreaming = StreamingOutputFormat.class.isAssignableFrom(clazz); - if (!isTez || isStreaming || this.isInsertOverwrite) { + if (isStreaming || this.isInsertOverwrite) { createBucketFiles(fsp); } } diff --git ql/src/java/org/apache/hadoop/hive/ql/exec/Utilities.java ql/src/java/org/apache/hadoop/hive/ql/exec/Utilities.java index e9966e6364..c2994cc8c9 100644 --- ql/src/java/org/apache/hadoop/hive/ql/exec/Utilities.java +++ ql/src/java/org/apache/hadoop/hive/ql/exec/Utilities.java @@ -4382,14 +4382,9 @@ public static void handleDirectInsertTableFinalPath(Path specPath, String unionS for (int i = 0; i < directInsertDirectories.size(); ++i) { finalResults[i] = new PathOnlyFileStatus(directInsertDirectories.get(i)); } - List emptyBuckets = Utilities.removeTempOrDuplicateFiles(fs, finalResults, + Utilities.removeTempOrDuplicateFiles(fs, finalResults, unionSuffix, dpLevels, mbc == null ? 0 : mbc.numBuckets, hconf, writeId, stmtId, isMmTable, null, isInsertOverwrite); - // create empty buckets if necessary - if (!emptyBuckets.isEmpty()) { - assert mbc != null; - Utilities.createEmptyBuckets(hconf, emptyBuckets, mbc.isCompressed, mbc.tableInfo, reporter); - } } }