Index: ql/src/java/org/apache/hadoop/hive/ql/exec/tez/SplitGrouper.java =================================================================== --- ql/src/java/org/apache/hadoop/hive/ql/exec/tez/SplitGrouper.java (revision 1675013) +++ ql/src/java/org/apache/hadoop/hive/ql/exec/tez/SplitGrouper.java (working copy) @@ -94,10 +94,10 @@ InputSplit[] groupedSplits = tezGrouper.getGroupedSplits(conf, rawSplits, bucketTaskMap.get(bucketId), HiveInputFormat.class.getName(), splitSizeEstimator); - + String splitSizeEstStr = splitSizeEstimator == null ? "null" : splitSizeEstimator.getClass().getSimpleName(); LOG.info("Original split size is " + rawSplits.length + " grouped split size is " + groupedSplits.length + ", for bucket: " + bucketId + " SplitSizeEstimator: " + - splitSizeEstimator.getClass().getSimpleName()); + splitSizeEstStr); for (InputSplit inSplit : groupedSplits) { bucketGroupedSplitMultimap.put(bucketId, inSplit);