fix: set wal apply version on vnode reopen
This commit is contained in:
parent
dafde51767
commit
1e5dc921e0
|
@ -122,7 +122,6 @@ static void *mndThreadFp(void *param) {
|
||||||
if (lastTime % 10 != 0) continue;
|
if (lastTime % 10 != 0) continue;
|
||||||
|
|
||||||
int64_t sec = lastTime / 10;
|
int64_t sec = lastTime / 10;
|
||||||
|
|
||||||
if (sec % tsTtlPushInterval == 0) {
|
if (sec % tsTtlPushInterval == 0) {
|
||||||
mndPullupTtl(pMnode);
|
mndPullupTtl(pMnode);
|
||||||
}
|
}
|
||||||
|
|
|
@ -688,6 +688,8 @@ static void vnodeRestoreFinish(struct SSyncFSM *pFsm) {
|
||||||
}
|
}
|
||||||
} while (true);
|
} while (true);
|
||||||
|
|
||||||
|
walApplyVer(pVnode->pWal, pVnode->state.applied);
|
||||||
|
|
||||||
pVnode->restored = true;
|
pVnode->restored = true;
|
||||||
vDebug("vgId:%d, sync restore finished", pVnode->config.vgId);
|
vDebug("vgId:%d, sync restore finished", pVnode->config.vgId);
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue