.../main/java/org/apache/hadoop/hbase/mapreduce/PutCombiner.java | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/PutCombiner.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/PutCombiner.java index f10836b..f4dd972 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/PutCombiner.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/PutCombiner.java @@ -20,8 +20,8 @@ package org.apache.hadoop.hbase.mapreduce; import java.io.IOException; import java.util.List; -import java.util.Map.Entry; import java.util.Map; +import java.util.Map.Entry; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; @@ -78,6 +78,10 @@ public class PutCombiner extends Reducer { familyMap.put(entry.getKey(), entry.getValue()); } } + // Add all the attributes + for (Map.Entry entry : p.getAttributesMap().entrySet()) { + put.setAttribute(entry.getKey(), entry.getValue()); + } if (cnt % 10 == 0) context.setStatus("Combine " + cnt); if (curSize > threshold) { LOG.info(String.format("Combined %d Put(s) into %d.", cnt, 1));