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 267d6029ac..adbba55eba 100644 --- ql/src/java/org/apache/hadoop/hive/ql/exec/FileSinkOperator.java +++ ql/src/java/org/apache/hadoop/hive/ql/exec/FileSinkOperator.java @@ -1256,13 +1256,8 @@ public void closeOp(boolean abort) throws HiveException { } if (!bDynParts && !filesCreated) { - boolean skipFiles = "tez".equalsIgnoreCase( - HiveConf.getVar(hconf, ConfVars.HIVE_EXECUTION_ENGINE)); - if (skipFiles) { - Class clazz = conf.getTableInfo().getOutputFileFormatClass(); - skipFiles = !StreamingOutputFormat.class.isAssignableFrom(clazz); - } - if (!skipFiles) { + Class clazz = conf.getTableInfo().getOutputFileFormatClass(); + if (StreamingOutputFormat.class.isAssignableFrom(clazz)) { createBucketFiles(fsp); } }