fix: avoid sync restore repeat called

46889e2d · Shengliang Guan · 6f44934f · 46889e2d
隐藏空白更改
内联并排

Showing with 7 addition and 3 deletion

source/dnode/mnode/impl/src/mndSync.c source/dnode/mnode/impl/src/mndSync.c +7 -3

未找到文件。
--- a/source/dnode/mnode/impl/src/mndSync.c
+++ b/source/dnode/mnode/impl/src/mndSync.c
@@ -149,9 +149,13 @@ void mndRestoreFinish(const SSyncFSM *pFsm) {
  SMnode *pMnode = pFsm->data;

  if (!pMnode->deploy) {
-    mInfo("vgId:1, sync restore finished, and will handle outstanding transactions");
-    mndTransPullup(pMnode);
-    mndSetRestored(pMnode, true);
+    if (pMnode->restored) {
+      mInfo("vgId:1, sync restore finished, and will handle outstanding transactions");
+      mndTransPullup(pMnode);
+      mndSetRestored(pMnode, true);
+    } else {
+      mInfo("vgId:1, sync restore finished, repeat call");
+    }
  } else {
    mInfo("vgId:1, sync restore finished");
  }