You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by pv...@apache.org on 2017/08/11 09:44:29 UTC
hive git commit: HIVE-17251: Remove usage of
org.apache.pig.ResourceStatistics#setmBytes method in HCatLoader (Adam Szita,
reviewed by Mithun Radhakrishnan)
Repository: hive
Updated Branches:
refs/heads/master 35139a61f -> 4a14cfc01
HIVE-17251: Remove usage of org.apache.pig.ResourceStatistics#setmBytes method in HCatLoader (Adam Szita, reviewed by Mithun Radhakrishnan)
Project: http://git-wip-us.apache.org/repos/asf/hive/repo
Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/4a14cfc0
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/4a14cfc0
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/4a14cfc0
Branch: refs/heads/master
Commit: 4a14cfc01b6c06817899290b6d2c5f0849cb44dd
Parents: 35139a6
Author: Peter Vary <pv...@cloudera.com>
Authored: Fri Aug 11 11:43:01 2017 +0200
Committer: Peter Vary <pv...@cloudera.com>
Committed: Fri Aug 11 11:43:01 2017 +0200
----------------------------------------------------------------------
.../src/main/java/org/apache/hive/hcatalog/pig/HCatLoader.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hive/blob/4a14cfc0/hcatalog/hcatalog-pig-adapter/src/main/java/org/apache/hive/hcatalog/pig/HCatLoader.java
----------------------------------------------------------------------
diff --git a/hcatalog/hcatalog-pig-adapter/src/main/java/org/apache/hive/hcatalog/pig/HCatLoader.java b/hcatalog/hcatalog-pig-adapter/src/main/java/org/apache/hive/hcatalog/pig/HCatLoader.java
index d98f40c..a6f01d0 100644
--- a/hcatalog/hcatalog-pig-adapter/src/main/java/org/apache/hive/hcatalog/pig/HCatLoader.java
+++ b/hcatalog/hcatalog-pig-adapter/src/main/java/org/apache/hive/hcatalog/pig/HCatLoader.java
@@ -262,7 +262,7 @@ public class HCatLoader extends HCatBaseLoader {
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);