diff --git hcatalog/hcatalog-pig-adapter/src/main/java/org/apache/hive/hcatalog/pig/HCatLoader.java hcatalog/hcatalog-pig-adapter/src/main/java/org/apache/hive/hcatalog/pig/HCatLoader.java index d98f40c88b0540ee667a571d50793b4a03558607..a6f01d0062069e117f0579e74a0b3b40854bb963 100644 --- hcatalog/hcatalog-pig-adapter/src/main/java/org/apache/hive/hcatalog/pig/HCatLoader.java +++ hcatalog/hcatalog-pig-adapter/src/main/java/org/apache/hive/hcatalog/pig/HCatLoader.java @@ -262,7 +262,7 @@ public ResourceStatistics getStatistics(String location, Job job) throws IOExcep ResourceStatistics stats = new ResourceStatistics(); InputJobInfo inputJobInfo = (InputJobInfo) HCatUtil.deserialize( job.getConfiguration().get(HCatConstants.HCAT_KEY_JOB_INFO)); - stats.setmBytes(getSizeInBytes(inputJobInfo) / 1024 / 1024); + stats.setSizeInBytes(getSizeInBytes(inputJobInfo)); return stats; } catch (Exception e) { throw new IOException(e);