fix(tsdb): fix error in decide if data buffer overlaps with stt files/block-files.
This commit is contained in:
parent
cb43299faa
commit
00626de6e4
|
@ -1200,8 +1200,8 @@ static bool bufferDataInFileBlockGap(int32_t order, TSDBKEY keyInBuf, SFileDataB
|
||||||
bool ascScan = ASCENDING_TRAVERSE(order);
|
bool ascScan = ASCENDING_TRAVERSE(order);
|
||||||
int64_t key = ascScan? MIN(pBlock->record.firstKey, keyInStt):MAX(pBlock->record.lastKey, keyInStt);
|
int64_t key = ascScan? MIN(pBlock->record.firstKey, keyInStt):MAX(pBlock->record.lastKey, keyInStt);
|
||||||
|
|
||||||
return (ascScan && (keyInBuf.ts != TSKEY_INITIAL_VAL && keyInBuf.ts <= key)) ||
|
return (ascScan && (keyInBuf.ts != TSKEY_INITIAL_VAL && keyInBuf.ts < key)) ||
|
||||||
(!ascScan && (keyInBuf.ts != TSKEY_INITIAL_VAL && keyInBuf.ts >= key));
|
(!ascScan && (keyInBuf.ts != TSKEY_INITIAL_VAL && keyInBuf.ts > key));
|
||||||
}
|
}
|
||||||
|
|
||||||
static bool keyOverlapFileBlock(TSDBKEY key, SFileDataBlockInfo* pBlock, SVersionRange* pVerRange) {
|
static bool keyOverlapFileBlock(TSDBKEY key, SFileDataBlockInfo* pBlock, SVersionRange* pVerRange) {
|
||||||
|
|
Loading…
Reference in New Issue