.../apache/hadoop/hbase/regionserver/CellArrayImmutableSegment.java | 2 +- .../apache/hadoop/hbase/regionserver/CellChunkImmutableSegment.java | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/CellArrayImmutableSegment.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/CellArrayImmutableSegment.java index a4b8c7b..e112eaa 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/CellArrayImmutableSegment.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/CellArrayImmutableSegment.java @@ -125,7 +125,7 @@ public class CellArrayImmutableSegment extends ImmutableSegment { segmentScanner.close(); } // build the immutable CellSet - CellArrayMap cam = new CellArrayMap(CellComparator.COMPARATOR, cells, 0, idx, false); + CellArrayMap cam = new CellArrayMap(getComparator(), cells, 0, idx, false); this.setCellSet(oldCellSet, new CellSet(cam)); // update the CellSet of this Segment } diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/CellChunkImmutableSegment.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/CellChunkImmutableSegment.java index 62b62da..62ed0c9 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/CellChunkImmutableSegment.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/CellChunkImmutableSegment.java @@ -124,7 +124,7 @@ public class CellChunkImmutableSegment extends ImmutableSegment { } // build the immutable CellSet CellChunkMap ccm = - new CellChunkMap(CellComparator.COMPARATOR,chunks,0,numOfCellsAfterCompaction,false); + new CellChunkMap(getComparator(), chunks, 0, numOfCellsAfterCompaction, false); this.setCellSet(null, new CellSet(ccm)); // update the CellSet of this Segment } @@ -167,7 +167,7 @@ public class CellChunkImmutableSegment extends ImmutableSegment { segmentScanner.close(); } - CellChunkMap ccm = new CellChunkMap(CellComparator.COMPARATOR,chunks,0,numOfCells,false); + CellChunkMap ccm = new CellChunkMap(getComparator(), chunks, 0, numOfCells, false); this.setCellSet(oldCellSet, new CellSet(ccm)); // update the CellSet of this Segment }