From b9bda9b30f6c267e60adf53532f4342e3ec3aaac Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Wed, 17 May 2023 19:36:42 +0800 Subject: [PATCH] fix(stream): set the correct start offset for resumed stream task. --- source/dnode/vnode/src/tq/tq.c | 1 + 1 file changed, 1 insertion(+) diff --git a/source/dnode/vnode/src/tq/tq.c b/source/dnode/vnode/src/tq/tq.c index 6d700c5c9f..0179480011 100644 --- a/source/dnode/vnode/src/tq/tq.c +++ b/source/dnode/vnode/src/tq/tq.c @@ -1440,6 +1440,7 @@ int32_t tqProcessTaskResumeReq(STQ* pTq, int64_t sversion, char* msg, int32_t ms // no lock needs to secure the access of the version if (pReq->igUntreated) { // discard all the data when the stream task is suspended. pTask->chkInfo.currentVer = sversion; + walReaderSeekVer(pTask->exec.pWalReader, sversion); tqDebug("vgId:%d s-task:%s resume to normal from the latest version:%" PRId64 ", vnode ver:%" PRId64, pTq->pStreamMeta->vgId, pTask->id.idStr, pTask->chkInfo.currentVer, sversion); } else { // from the previous paused version and go on