From 8aad71c92843a3f181811a8c64f123e5c2b10c1e Mon Sep 17 00:00:00 2001
From: Hongze Cheng <hzcheng@taosdata.com>
Date: Sun, 4 Dec 2022 10:07:08 +0800
Subject: [PATCH] more code

---
 source/dnode/vnode/src/vnd/vnodeCommit.c | 1 +
 source/dnode/vnode/src/vnd/vnodeSvr.c    | 4 ++++
 2 files changed, 5 insertions(+)

diff --git a/source/dnode/vnode/src/vnd/vnodeCommit.c b/source/dnode/vnode/src/vnd/vnodeCommit.c
index 79e4f46241..6ef5116fdc 100644
--- a/source/dnode/vnode/src/vnd/vnodeCommit.c
+++ b/source/dnode/vnode/src/vnd/vnodeCommit.c
@@ -232,6 +232,7 @@ int vnodeAsyncCommit(SVnode *pVnode) {
   pInfo->info.state.committed = pVnode->state.applied;
   pInfo->info.state.commitTerm = pVnode->state.applyTerm;
   pInfo->info.state.commitID = pVnode->state.commitID;
+  pInfo->pVnode = pVnode;
   vnodeScheduleTask(vnodeCommitTask, pInfo);
 
 _exit:
diff --git a/source/dnode/vnode/src/vnd/vnodeSvr.c b/source/dnode/vnode/src/vnd/vnodeSvr.c
index afb4edab7a..daeda530fd 100644
--- a/source/dnode/vnode/src/vnd/vnodeSvr.c
+++ b/source/dnode/vnode/src/vnd/vnodeSvr.c
@@ -313,7 +313,11 @@ int32_t vnodeProcessWriteMsg(SVnode *pVnode, SRpcMsg *pMsg, int64_t version, SRp
   // commit if need
   if (vnodeShouldCommit(pVnode)) {
     vInfo("vgId:%d, commit at version %" PRId64, TD_VID(pVnode), version);
+#if 1
+    vnodeSyncCommit(pVnode);
+#else
     vnodeAsyncCommit(pVnode);
+#endif
 
     // start a new one
     if (vnodeBegin(pVnode) < 0) {