From a601cd21bd3f904f9628b40618a0b31cb488fc0e Mon Sep 17 00:00:00 2001
From: Hongze Cheng <hzcheng@taosdata.com>
Date: Wed, 23 Aug 2023 13:31:19 +0800
Subject: [PATCH] fix: alter stt_trigger bug

---
 source/dnode/vnode/src/tsdb/tsdbCommit2.c | 47 +++++++++++------------
 1 file changed, 22 insertions(+), 25 deletions(-)

diff --git a/source/dnode/vnode/src/tsdb/tsdbCommit2.c b/source/dnode/vnode/src/tsdb/tsdbCommit2.c
index afbe895721..d4cb63fb7b 100644
--- a/source/dnode/vnode/src/tsdb/tsdbCommit2.c
+++ b/source/dnode/vnode/src/tsdb/tsdbCommit2.c
@@ -235,36 +235,33 @@ static int32_t tsdbCommitOpenReader(SCommitter2 *committer) {
     return 0;
   }
 
-  ASSERT(TARRAY2_SIZE(committer->ctx->fset->lvlArr) == 1);
+  SSttLvl *lvl;
+  TARRAY2_FOREACH(committer->ctx->fset->lvlArr, lvl) {
+    STFileObj *fobj = NULL;
+    TARRAY2_FOREACH(lvl->fobjArr, fobj) {
+      SSttFileReader *sttReader;
 
-  SSttLvl *lvl = TARRAY2_FIRST(committer->ctx->fset->lvlArr);
+      SSttFileReaderConfig config = {
+          .tsdb = committer->tsdb,
+          .szPage = committer->szPage,
+          .file = fobj->f[0],
+      };
 
-  ASSERT(lvl->level == 0);
+      code = tsdbSttFileReaderOpen(fobj->fname, &config, &sttReader);
+      TSDB_CHECK_CODE(code, lino, _exit);
 
-  STFileObj *fobj = NULL;
-  TARRAY2_FOREACH(lvl->fobjArr, fobj) {
-    SSttFileReader *sttReader;
+      code = TARRAY2_APPEND(committer->sttReaderArray, sttReader);
+      TSDB_CHECK_CODE(code, lino, _exit);
 
-    SSttFileReaderConfig config = {
-        .tsdb = committer->tsdb,
-        .szPage = committer->szPage,
-        .file = fobj->f[0],
-    };
+      STFileOp op = {
+          .optype = TSDB_FOP_REMOVE,
+          .fid = fobj->f->fid,
+          .of = fobj->f[0],
+      };
 
-    code = tsdbSttFileReaderOpen(fobj->fname, &config, &sttReader);
-    TSDB_CHECK_CODE(code, lino, _exit);
-
-    code = TARRAY2_APPEND(committer->sttReaderArray, sttReader);
-    TSDB_CHECK_CODE(code, lino, _exit);
-
-    STFileOp op = {
-        .optype = TSDB_FOP_REMOVE,
-        .fid = fobj->f->fid,
-        .of = fobj->f[0],
-    };
-
-    code = TARRAY2_APPEND(committer->fopArray, op);
-    TSDB_CHECK_CODE(code, lino, _exit);
+      code = TARRAY2_APPEND(committer->fopArray, op);
+      TSDB_CHECK_CODE(code, lino, _exit);
+    }
   }
 
 _exit: