fix TSDB commit problem

598d8deb · Hongze Cheng · 9283f1cb · 598d8deb
隐藏空白更改
内联并排

Showing with 6 addition and 5 deletion

source/dnode/vnode/src/tsdb/tsdbCommit.c source/dnode/vnode/src/tsdb/tsdbCommit.c +6 -5

未找到文件。
--- a/source/dnode/vnode/src/tsdb/tsdbCommit.c
+++ b/source/dnode/vnode/src/tsdb/tsdbCommit.c
@@ -142,12 +142,13 @@ int tsdbPrepareCommit(STsdb *pTsdb) {
 }

 int tsdbCommit(STsdb *pRepo) {
-  STsdbMemTable *pMem = pRepo->imem;
-  SCommitH       commith = {0};
-  SDFileSet     *pSet = NULL;
-  int            fid;
+  SCommitH   commith = {0};
+  SDFileSet *pSet = NULL;
+  int        fid;

-  if (pRepo->imem == NULL) return 0;
+  // if (pRepo->imem == NULL) return 0;
+  pRepo->imem = pRepo->mem;
+  pRepo->mem = NULL;

  tsdbStartCommit(pRepo);
  // Resource initialization