fix:offset out of range if poll offset is read from offsetRestored while wal is deleted

This commit is contained in:
wangmm0220 2023-12-05 19:09:29 +08:00
parent 7589bbab45
commit cc51fd47d0
1 changed files with 1 additions and 0 deletions

View File

@ -168,6 +168,7 @@ static int32_t extractDataAndRspForNormalSubscribe(STQ* pTq, STqHandle* pHandle,
taosWUnLockLatch(&pTq->lock);
}
dataRsp.reqOffset = *pOffset; // reqOffset represents the current date offset, may be changed if wal not exists
code = tqSendDataRsp(pHandle, pMsg, pRequest, (SMqDataRsp*)&dataRsp, TMQ_MSG_TYPE__POLL_DATA_RSP, vgId);
end : {