diff --git a/sstable/colblk_writer.go b/sstable/colblk_writer.go index 04af124bd2..31edc7dd72 100644 --- a/sstable/colblk_writer.go +++ b/sstable/colblk_writer.go @@ -805,7 +805,7 @@ func (w *RawColumnWriter) flushDataBlockWithoutNextKey(nextKey []byte) error { // Invariant: w.dataBlockBuf.uncompressed must already be populated. func (w *RawColumnWriter) maybeIncrementTombstoneDenseBlocks(uncompressedLen int) { minSize := w.opts.DeletionSizeRatioThreshold * float32(uncompressedLen) - if w.dataBlock.numDeletions > w.opts.NumDeletionsThreshold || float32(w.dataBlock.deletionSize) > minSize { + if w.dataBlock.numDeletions >= w.opts.NumDeletionsThreshold || float32(w.dataBlock.deletionSize) > minSize { w.props.NumTombstoneDenseBlocks++ } w.dataBlock.numDeletions = 0 diff --git a/sstable/rowblk_writer.go b/sstable/rowblk_writer.go index 3642b32ca4..60d7a0378a 100644 --- a/sstable/rowblk_writer.go +++ b/sstable/rowblk_writer.go @@ -986,7 +986,7 @@ func (w *RawRowWriter) maybeAddToFilter(key []byte) { // Invariant: w.dataBlockBuf.uncompressed must already be populated. func (w *RawRowWriter) maybeIncrementTombstoneDenseBlocks() { minSize := w.deletionSizeRatioThreshold * float32(len(w.dataBlockBuf.uncompressed)) - if w.dataBlockBuf.numDeletions > w.numDeletionsThreshold || float32(w.dataBlockBuf.deletionSize) > minSize { + if w.dataBlockBuf.numDeletions >= w.numDeletionsThreshold || float32(w.dataBlockBuf.deletionSize) > minSize { w.props.NumTombstoneDenseBlocks++ } w.dataBlockBuf.numDeletions = 0