From 1e5dc921e0f57614f6d25db5a9b8b1183eb4438b Mon Sep 17 00:00:00 2001 From: Shengliang Guan Date: Mon, 26 Sep 2022 20:32:02 +0800 Subject: [PATCH] fix: set wal apply version on vnode reopen --- source/dnode/mnode/impl/src/mndMain.c | 1 - source/dnode/vnode/src/vnd/vnodeSync.c | 2 ++ 2 files changed, 2 insertions(+), 1 deletion(-) diff --git a/source/dnode/mnode/impl/src/mndMain.c b/source/dnode/mnode/impl/src/mndMain.c index e6b6aaacf1..32dda0b802 100644 --- a/source/dnode/mnode/impl/src/mndMain.c +++ b/source/dnode/mnode/impl/src/mndMain.c @@ -122,7 +122,6 @@ static void *mndThreadFp(void *param) { if (lastTime % 10 != 0) continue; int64_t sec = lastTime / 10; - if (sec % tsTtlPushInterval == 0) { mndPullupTtl(pMnode); } diff --git a/source/dnode/vnode/src/vnd/vnodeSync.c b/source/dnode/vnode/src/vnd/vnodeSync.c index a941b5955c..2c3808a703 100644 --- a/source/dnode/vnode/src/vnd/vnodeSync.c +++ b/source/dnode/vnode/src/vnd/vnodeSync.c @@ -688,6 +688,8 @@ static void vnodeRestoreFinish(struct SSyncFSM *pFsm) { } } while (true); + walApplyVer(pVnode->pWal, pVnode->state.applied); + pVnode->restored = true; vDebug("vgId:%d, sync restore finished", pVnode->config.vgId); }