more work
This commit is contained in:
parent
bb0f20f6e6
commit
d76912cc76
|
@ -505,8 +505,8 @@ static int32_t tsdbCommitFileDataImpl(SCommitter *pCommitter) {
|
|||
}
|
||||
}
|
||||
|
||||
if (pTbData && !tsdbTbDataIterOpen(pTbData, &(TSDBKEY){.ts = pCommitter->minKey, .version = 0}), 0,
|
||||
&pCommitter->iter) {
|
||||
if (pTbData &&
|
||||
!tsdbTbDataIterOpen(pTbData, &(TSDBKEY){.ts = pCommitter->minKey, .version = 0}, 0, &pCommitter->iter)) {
|
||||
pTbData = NULL;
|
||||
}
|
||||
|
||||
|
|
|
@ -493,7 +493,7 @@ int32_t tBlockCmprFn(const void *p1, const void *p2) {
|
|||
if (tsdbKeyCmprFn(&pBlock1->maxKey, &pBlock2->minKey) < 0) {
|
||||
return -1;
|
||||
} else if (tsdbKeyCmprFn(&pBlock1->minKey, &pBlock2->maxKey) > 0) {
|
||||
return 1
|
||||
return 1;
|
||||
}
|
||||
|
||||
return 0;
|
||||
|
|
Loading…
Reference in New Issue