From ae09d1d0319dff62c4eca8fb41a01d77ead94b4f Mon Sep 17 00:00:00 2001
From: yihaoDeng <cyang@taosdata.com>
Date: Mon, 5 Jun 2023 19:49:54 +0800
Subject: [PATCH] fix:wal error

---
 source/dnode/vnode/src/tq/tqUtil.c | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/source/dnode/vnode/src/tq/tqUtil.c b/source/dnode/vnode/src/tq/tqUtil.c
index 5b0e38182e..beb915d2a7 100644
--- a/source/dnode/vnode/src/tq/tqUtil.c
+++ b/source/dnode/vnode/src/tq/tqUtil.c
@@ -176,7 +176,7 @@ static int32_t extractDataAndRspForNormalSubscribe(STQ* pTq, STqHandle* pHandle,
   if (terrno == TSDB_CODE_WAL_LOG_NOT_EXIST && dataRsp.blockNum == 0) {
     // lock
     taosWLockLatch(&pTq->lock);
-    int64_t ver = walGetCommittedVer(pHandle->pWalReader->pWal);
+    int64_t ver = walGetCommittedVer(pTq->pVnode->pWal);
     if (pOffset->version >= ver || dataRsp.rspOffset.version >= ver){   //check if there are data again to avoid lost data
       code = tqRegisterPushHandle(pTq, pHandle, pMsg);
       taosWUnLockLatch(&pTq->lock);
@@ -424,4 +424,4 @@ int32_t tqDoSendDataRsp(const SRpcHandleInfo* pRpcHandleInfo, const SMqDataRsp*
 
   tmsgSendRsp(&rsp);
   return 0;
-}
\ No newline at end of file
+}
-- 
GitLab