tsdb/retention: not allow migrate backward

2023-11-14 19:27:18 +08:00 · 2023-11-14 19:27:18 +08:00 · 7f65e92b81
parent 88d2e00123
commit 7f65e92b81
1 changed files with 3 additions and 0 deletions
--- a/source/dnode/vnode/src/tsdb/tsdbRetention.c
+++ b/source/dnode/vnode/src/tsdb/tsdbRetention.c
@ -359,6 +359,9 @@ static int32_t tsdbDoRetentionOnFileSet(SRTNer *rtner, STFileSet *fset) {
        s3EvictCache(fobj->fname, fsize * 2);
      }
      */
+      if (fobj->f->did.level > did.level) {
+        continue;
+      }
      tsdbInfo("file:%s size: %" PRId64 " do migrate from %d to %d", fobj->fname, fobj->f->size, fobj->f->did.level,
               did.level);