Merge pull request #22186 from taosdata/fix/TD-25315
fix(tsdb/del): continue committing fileset if more del left
This commit is contained in:
commit
02bc1b2a8f
|
@ -189,6 +189,10 @@ static int32_t tsdbCommitTombData(SCommitter2 *committer) {
|
||||||
committer->ctx->maxKey = committer->ctx->maxKey + 1;
|
committer->ctx->maxKey = committer->ctx->maxKey + 1;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if (record->ekey > committer->ctx->maxKey) {
|
||||||
|
committer->ctx->nextKey = committer->ctx->maxKey;
|
||||||
|
}
|
||||||
|
|
||||||
record->skey = TMAX(record->skey, committer->ctx->minKey);
|
record->skey = TMAX(record->skey, committer->ctx->minKey);
|
||||||
record->ekey = TMIN(record->ekey, committer->ctx->maxKey);
|
record->ekey = TMIN(record->ekey, committer->ctx->maxKey);
|
||||||
|
|
||||||
|
@ -602,4 +606,4 @@ _exit:
|
||||||
tsdbInfo("vgId:%d %s done", TD_VID(pTsdb->pVnode), __func__);
|
tsdbInfo("vgId:%d %s done", TD_VID(pTsdb->pVnode), __func__);
|
||||||
}
|
}
|
||||||
return code;
|
return code;
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue