more code

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:

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) {