diff --git a/source/libs/stream/src/streamMeta.c b/source/libs/stream/src/streamMeta.c
index 35007bda1d..64d0d47abe 100644
--- a/source/libs/stream/src/streamMeta.c
+++ b/source/libs/stream/src/streamMeta.c
@@ -899,7 +899,7 @@ void metaHbToMnode(void* param, void* tmrId) {
 //    entry.outputRate = entry.outputQUsed*100.0/STREAM_TASK_QUEUE_CAPACITY_IN_SIZE;
 
     if ((*pTask)->exec.pWalReader != NULL) {
-      entry.offset = walReaderGetCurrentVer((*pTask)->exec.pWalReader);
+      entry.offset = (*pTask)->chkInfo.nextProcessVer;
       walReaderValidVersionRange((*pTask)->exec.pWalReader, &entry.verStart, &entry.verEnd);
     }