diff --git ql/src/java/org/apache/hadoop/hive/ql/stats/fs/FSStatsAggregator.java ql/src/java/org/apache/hadoop/hive/ql/stats/fs/FSStatsAggregator.java index 6d2de0a3ae..cb5fee4a48 100644 --- ql/src/java/org/apache/hadoop/hive/ql/stats/fs/FSStatsAggregator.java +++ ql/src/java/org/apache/hadoop/hive/ql/stats/fs/FSStatsAggregator.java @@ -86,7 +86,7 @@ public boolean accept(Path file) { @Override public String aggregateStats(String partID, String statType) { long counter = 0; - Utilities.FILE_OP_LOGGER.debug("Part ID: " + partID + "\t" + statType); + Utilities.FILE_OP_LOGGER.debug("Part ID: {}, {}", partID, statType); for (Map> statsMap : statsList) { Map partStat = statsMap.get(partID); if (null == partStat) { // not all partitions are scanned in all mappers, so this could be null. @@ -98,7 +98,7 @@ public String aggregateStats(String partID, String statType) { } counter += Long.parseLong(statVal); } - Utilities.FILE_OP_LOGGER.info("Read stats for : " + partID + "\t" + statType + "\t" + counter); + Utilities.FILE_OP_LOGGER.info("Read stats for {}, {}, {}: ", partID, statType, counter); return String.valueOf(counter); }