diff --git a/source/libs/stream/src/streamMeta.c b/source/libs/stream/src/streamMeta.c
index ea451c64e9..71d4beebb1 100644
--- a/source/libs/stream/src/streamMeta.c
+++ b/source/libs/stream/src/streamMeta.c
@@ -892,8 +892,11 @@ void metaHbToMnode(void* param, void* tmrId) {
 
     entry.inputRate = entry.inputQUsed*100.0/STREAM_TASK_INPUT_QUEUE_CAPACITY_IN_SIZE;
     entry.outputRate = entry.outputQUsed*100.0/STREAM_TASK_OUTPUT_QUEUE_CAPACITY_IN_SIZE;
-    entry.offset = walReaderGetCurrentVer((*pTask)->exec.pWalReader);
-    walReaderValidVersionRange((*pTask)->exec.pWalReader, &entry.verStart, &entry.verEnd);
+
+    if ((*pTask)->exec.pWalReader != NULL) {
+      entry.offset = walReaderGetCurrentVer((*pTask)->exec.pWalReader);
+      walReaderValidVersionRange((*pTask)->exec.pWalReader, &entry.verStart, &entry.verEnd);
+    }
 
     taosArrayPush(hbMsg.pTaskStatus, &entry);