tsdb/commit2: reset nextKey to max to stop commit

dd32f12f · Minglei Jin · 992d623a · dd32f12f
隐藏空白更改
内联并排

Showing with 2 addition and 0 deletion

source/dnode/vnode/src/tsdb/tsdbCommit2.c source/dnode/vnode/src/tsdb/tsdbCommit2.c +2 -0

未找到文件。
--- a/source/dnode/vnode/src/tsdb/tsdbCommit2.c
+++ b/source/dnode/vnode/src/tsdb/tsdbCommit2.c
@@ -164,6 +164,8 @@ static int32_t tsdbCommitTombData(SCommitter2 *committer) {
  if (committer->ctx->fset == NULL && !committer->ctx->hasTSData) {
    if (committer->ctx->maxKey < committer->ctx->maxDelKey) {
      committer->ctx->nextKey = committer->ctx->maxKey + 1;
+    } else {
+      committer->ctx->nextKey = TSKEY_MAX;
    }
    return 0;
  }