From df9ba31d81fd943d884ee5dc51437dbdf6dbc1fc Mon Sep 17 00:00:00 2001
From: Hongze Cheng <hzcheng@taosdata.com>
Date: Mon, 29 Nov 2021 18:37:04 +0800
Subject: [PATCH] more

---
 source/dnode/vnode/impl/src/vnodeWrite.c | 9 +++++----
 1 file changed, 5 insertions(+), 4 deletions(-)

diff --git a/source/dnode/vnode/impl/src/vnodeWrite.c b/source/dnode/vnode/impl/src/vnodeWrite.c
index 08c2bd3542..ee4c6e5443 100644
--- a/source/dnode/vnode/impl/src/vnodeWrite.c
+++ b/source/dnode/vnode/impl/src/vnodeWrite.c
@@ -24,9 +24,10 @@ int vnodeProcessWMsgs(SVnode *pVnode, SArray *pMsgs) {
 
     // ser request version
     void **pBuf = &(pMsg->pCont);
-    taosEncodeFixedU64(pBuf, pVnode->state.processed++);
+    uint64_t ver = pVnode->state.processed++;
+    taosEncodeFixedU64(pBuf, ver);
 
-    if (walWrite(pVnode->pWal, pVnodeReq->ver, pMsg->pCont, pMsg->contLen) < 0) {
+    if (walWrite(pVnode->pWal, ver, pMsg->pCont, pMsg->contLen) < 0) {
       // TODO: handle error
     }
   }
@@ -76,9 +77,9 @@ int vnodeProcessWMsgs(SVnode *pVnode, SArray *pMsgs) {
         default:
           break;
       }
-    }
 
-    pVnode->state.applied = pVnodeReq->ver;
+      pVnode->state.applied = ver;
+    }
 
     // Check if it needs to commit
     if (vnodeShouldCommit(pVnode)) {