Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-18992 Comparators passed to the Memstore's flattened segments seems 

to be wrong (Ram)
This commit is contained in:
Ramkrishna 2017-10-12 21:58:48 +05:30
parent 138a7392e3
commit e7b4f6046a
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/CellArrayImmutableSegment.java
View File

@ -125,7 +125,7 @@ public class CellArrayImmutableSegment extends ImmutableSegment {
segmentScanner.close(); segmentScanner.close();
} }
// build the immutable CellSet // 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 this.setCellSet(oldCellSet, new CellSet(cam)); // update the CellSet of this Segment
} }

4
hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/CellChunkImmutableSegment.java
View File

@ -124,7 +124,7 @@ public class CellChunkImmutableSegment extends ImmutableSegment {
} }
// build the immutable CellSet // build the immutable CellSet
CellChunkMap ccm = 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 this.setCellSet(null, new CellSet(ccm)); // update the CellSet of this Segment
} }
@ -167,7 +167,7 @@ public class CellChunkImmutableSegment extends ImmutableSegment {
segmentScanner.close(); 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 this.setCellSet(oldCellSet, new CellSet(ccm)); // update the CellSet of this Segment
} }