From 5e9d263e194af4c3d61ad79a17deb7d1e8ab43df Mon Sep 17 00:00:00 2001 From: Hongze Cheng Date: Wed, 21 Jun 2023 15:08:16 +0800 Subject: [PATCH] fix: infinite loop --- source/dnode/vnode/src/tsdb/tsdbCommit2.c | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/source/dnode/vnode/src/tsdb/tsdbCommit2.c b/source/dnode/vnode/src/tsdb/tsdbCommit2.c index 4de7705919..db7abf443c 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); } -- GitLab