diff --git a/source/dnode/vnode/src/vnd/vnodeCommit.c b/source/dnode/vnode/src/vnd/vnodeCommit.c index b8d2f3001d90b4b95a1f18c858a50f9403dca13d..9b2909aa09e190636db8249631a721ef06d30a33 100644 --- a/source/dnode/vnode/src/vnd/vnodeCommit.c +++ b/source/dnode/vnode/src/vnd/vnodeCommit.c @@ -198,7 +198,7 @@ int vnodeCommit(SVnode *pVnode) { // save info info.config = pVnode->config; - info.state = pVnode->state; + info.state.committed = pVnode->state.processed; snprintf(dir, TSDB_FILENAME_LEN, "%s%s%s", tfsGetPrimaryPath(pVnode->pTfs), TD_DIRSEP, pVnode->path); if (vnodeSaveInfo(dir, &info) < 0) { ASSERT(0); diff --git a/source/dnode/vnode/src/vnd/vnodeOpen.c b/source/dnode/vnode/src/vnd/vnodeOpen.c index 7dfab5edca769a710720ea2aa3bc48d29cb8649d..b51f0283b510808ba7ecda7124eafa68332d968c 100644 --- a/source/dnode/vnode/src/vnd/vnodeOpen.c +++ b/source/dnode/vnode/src/vnd/vnodeOpen.c @@ -144,7 +144,7 @@ _err: void vnodeClose(SVnode *pVnode) { if (pVnode) { // commit (TODO: use option to control) - vnodeSyncCommit(pVnode); + vnodeCommit(pVnode); // close vnode vnodeQueryClose(pVnode); walClose(pVnode->pWal);