diff --git a/source/dnode/vnode/src/tsdb/tsdbCommit2.c b/source/dnode/vnode/src/tsdb/tsdbCommit2.c index 4de7705919790da4e0be2e4867aa845f59f8592d..db7abf443c111ac2efba988efb442733c0f5b81f 100644 --- a/source/dnode/vnode/src/tsdb/tsdbCommit2.c +++ b/source/dnode/vnode/src/tsdb/tsdbCommit2.c @@ -142,10 +142,10 @@ static int32_t tsdbCommitTombData(SCommitter2 *committer) { for (STombRecord *record; (record = tsdbIterMergerGetTombRecord(committer->tombIterMerger));) { if (record->ekey < committer->ctx->minKey) { - continue; + goto _next; } else if (record->skey > committer->ctx->maxKey) { committer->ctx->maxKey = TMIN(record->skey, committer->ctx->maxKey); - continue; + goto _next; } if (record->ekey > committer->ctx->maxKey) { @@ -158,6 +158,7 @@ static int32_t tsdbCommitTombData(SCommitter2 *committer) { code = tsdbFSetWriteTombRecord(committer->writer, record); TSDB_CHECK_CODE(code, lino, _exit); + _next: code = tsdbIterMergerNext(committer->tombIterMerger); TSDB_CHECK_CODE(code, lino, _exit); }