more work
This commit is contained in:
parent
44c473303f
commit
aac1fb643f
|
@ -1034,6 +1034,11 @@ static int32_t tsdbCommitTableData(SCommitter *pCommitter, STbData *pTbData, SBl
|
||||||
|
|
||||||
pRow = tsdbTbDataIterGet(pIter);
|
pRow = tsdbTbDataIterGet(pIter);
|
||||||
iBlock++;
|
iBlock++;
|
||||||
|
if (iBlock < nBlock) {
|
||||||
|
tMapDataGetItemByIdx(&pCommitter->oBlockMap, iBlock, pBlock, tGetBlock);
|
||||||
|
} else {
|
||||||
|
pBlock = NULL;
|
||||||
|
}
|
||||||
} else {
|
} else {
|
||||||
int32_t c = tBlockCmprFn(&(SBlock){.maxKey = TSDBROW_KEY(pRow), .minKey = TSDBROW_KEY(pRow)}, pBlock);
|
int32_t c = tBlockCmprFn(&(SBlock){.maxKey = TSDBROW_KEY(pRow), .minKey = TSDBROW_KEY(pRow)}, pBlock);
|
||||||
if (c > 0) {
|
if (c > 0) {
|
||||||
|
|
Loading…
Reference in New Issue