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

HBASE-27034 NegativeArraySizeException was encountered during compaction

This commit is contained in:
xianjing feng 2022-05-14 12:38:15 +08:00
parent 369adcdf35
commit 7c4f7367dd
1 changed files with 2 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
hbase-server/src/main/java/org/apache/hadoop/hbase/io/hfile/HFileWriterImpl.java
View File

@ -550,7 +550,7 @@ public class HFileWriterImpl implements HFile.Writer {
blockWriter.startWriting(BlockType.DATA);
firstCellInBlock = null;
if (lastCell != null) {
lastCellOfPreviousBlock = lastCell;
lastCellOfPreviousBlock = KeyValueUtil.toNewKeyCell(lastCell);
}
}
@ -728,7 +728,7 @@ public class HFileWriterImpl implements HFile.Writer {
if (firstCellInBlock == null) {
// If cell is big, block will be closed and this firstCellInBlock reference will only last
// a short while.
firstCellInBlock = cell;
firstCellInBlock = KeyValueUtil.toNewKeyCell(cell);
}
// TODO: What if cell is 10MB and we write infrequently? We hold on to cell here indefinitely?
@ -748,12 +748,6 @@ public class HFileWriterImpl implements HFile.Writer {
if (this.lastCell != null) {
this.lastCell = KeyValueUtil.toNewKeyCell(this.lastCell);
}
if (this.firstCellInBlock != null) {
this.firstCellInBlock = KeyValueUtil.toNewKeyCell(this.firstCellInBlock);
}
if (this.lastCellOfPreviousBlock != null) {
this.lastCellOfPreviousBlock = KeyValueUtil.toNewKeyCell(this.lastCellOfPreviousBlock);
}
}
public Cell getLastCell() {