Skip to content

Commit b03ea4b

Browse files
authored
Merge pull request #1 from offermannu/offermannu-patch-HBASE-25839
Update Import.java
2 parents fda324b + 9989a50 commit b03ea4b

File tree

1 file changed

+2
-4
lines changed
  • hbase-mapreduce/src/main/java/org/apache/hadoop/hbase/mapreduce

1 file changed

+2
-4
lines changed

hbase-mapreduce/src/main/java/org/apache/hadoop/hbase/mapreduce/Import.java

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -135,9 +135,7 @@ public CellWritableComparable(Cell kv) {
135135

136136
@Override
137137
public void write(DataOutput out) throws IOException {
138-
out.writeInt(PrivateCellUtil.estimatedSerializedSizeOfKey(kv));
139-
out.writeInt(0);
140-
PrivateCellUtil.writeFlatKey(kv, out);
138+
KeyValueUtil.write(new KeyValue(kv), out);
141139
}
142140

143141
@Override
@@ -219,7 +217,7 @@ public void map(ImmutableBytesWritable row, Result value,
219217
// skip if we filtered it out
220218
if (kv == null) continue;
221219
Cell ret = convertKv(kv, cfRenameMap);
222-
context.write(new CellWritableComparable(ret), ret);
220+
context.write(new CellWritableComparable(ret), new MapReduceExtendedCell(ret));
223221
}
224222
}
225223
} catch (InterruptedException e) {

0 commit comments

Comments
 (0)