You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by ns...@apache.org on 2012/01/05 00:46:20 UTC
svn commit: r1227391 -
/hbase/branches/0.89-fb/src/main/java/org/apache/hadoop/hbase/mapreduce/PutSortReducer.java
Author: nspiegelberg
Date: Wed Jan 4 23:46:19 2012
New Revision: 1227391
URL: http://svn.apache.org/viewvc?rev=1227391&view=rev
Log:
[HBASE-5014] PutSortReducer should adhere to memory limits
Modified:
hbase/branches/0.89-fb/src/main/java/org/apache/hadoop/hbase/mapreduce/PutSortReducer.java
Modified: hbase/branches/0.89-fb/src/main/java/org/apache/hadoop/hbase/mapreduce/PutSortReducer.java
URL: http://svn.apache.org/viewvc/hbase/branches/0.89-fb/src/main/java/org/apache/hadoop/hbase/mapreduce/PutSortReducer.java?rev=1227391&r1=1227390&r2=1227391&view=diff
==============================================================================
--- hbase/branches/0.89-fb/src/main/java/org/apache/hadoop/hbase/mapreduce/PutSortReducer.java (original)
+++ hbase/branches/0.89-fb/src/main/java/org/apache/hadoop/hbase/mapreduce/PutSortReducer.java Wed Jan 4 23:46:19 2012
@@ -61,7 +61,7 @@ public class PutSortReducer extends
for (List<KeyValue> kvs : p.getFamilyMap().values()) {
for (KeyValue kv : kvs) {
map.add(kv);
- curSize += kv.getValueLength();
+ curSize += kv.getLength();
}
}
}