xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

tsdb/commit: make ts big enough to skip row

This commit is contained in:
Minglei Jin 2023-10-26 16:24:06 +08:00
parent 7b48ea1f04
commit b314758108
1 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
source/dnode/vnode/src/tsdb/tsdbCommit2.c
View File

@ -137,7 +137,12 @@ static int32_t tsdbCommitTSData(SCommitter2 *committer) {
}
int64_t ts = TSDBROW_TS(&row->row);
if (ts > committer->ctx->maxKey || skipRow) {
if (skipRow && ts <= committer->ctx->maxKey) {
ts = committer->ctx->maxKey + 1;
}
if (ts > committer->ctx->maxKey) {
committer->ctx->nextKey = TMIN(committer->ctx->nextKey, ts);
code = tsdbIterMergerSkipTableData(committer->dataIterMerger, committer->ctx->tbid);
TSDB_CHECK_CODE(code, lino, _exit);