diff --git a/source/dnode/vnode/src/tq/tqStreamTask.c b/source/dnode/vnode/src/tq/tqStreamTask.c
index 0167ffc017..07a0888802 100644
--- a/source/dnode/vnode/src/tq/tqStreamTask.c
+++ b/source/dnode/vnode/src/tq/tqStreamTask.c
@@ -156,13 +156,13 @@ void tqScanWalAsync(STQ* pTq) {
   // 2. the stream isn't disabled
   if ((pMeta->role == NODE_ROLE_FOLLOWER) || tsDisableStream) {
     tqInfo("vgId:%d follower node or stream disabled, not scan wal", vgId);
-    return TSDB_CODE_SUCCESS;
+    return;
   }
 
   pParam = taosMemoryMalloc(sizeof(SBuildScanWalMsgParam));
   if (pParam == NULL) {
     tqError("vgId:%d failed to start scan wal, stream not executes, code:%s", vgId, tstrerror(code));
-    return terrno;
+    return;
   }
 
   pParam->metaId = pMeta->rid;
diff --git a/source/dnode/vnode/src/tq/tqUtil.c b/source/dnode/vnode/src/tq/tqUtil.c
index 217859394a..6f001981fb 100644
--- a/source/dnode/vnode/src/tq/tqUtil.c
+++ b/source/dnode/vnode/src/tq/tqUtil.c
@@ -49,7 +49,7 @@ void tqUpdateNodeStage(STQ* pTq, bool isLeader) {
   streamMetaUpdateStageRole(pTq->pStreamMeta, state.term, isLeader);
 
   if (isLeader) {
-    int32_t code = tqScanWalAsync(pTq);
+    tqScanWalAsync(pTq);
   }
 }