diff --git ql/src/java/org/apache/hadoop/hive/ql/io/HiveInputFormat.java ql/src/java/org/apache/hadoop/hive/ql/io/HiveInputFormat.java index 7987c4e70e..0e51f7f1da 100755 --- ql/src/java/org/apache/hadoop/hive/ql/io/HiveInputFormat.java +++ ql/src/java/org/apache/hadoop/hive/ql/io/HiveInputFormat.java @@ -554,8 +554,13 @@ private void addSplitsForGroup(List dirs, TableScanOperator tableScan, Job processForWriteIds(dir, conf, validWriteIdList, finalPaths); } if (finalPaths.isEmpty()) { - LOG.warn("No valid inputs found in " + dirs); - return null; + if (!conf.getBoolean(Utilities.ENSURE_OPERATORS_EXECUTED, false)) { + LOG.warn("No valid inputs found in " + dirs); + return null; + } else { + // Return Path[] for GroupByOperator summary row. + return dirs.toArray(new Path[dirs.size()]); + } } return finalPaths.toArray(new Path[finalPaths.size()]); }