From 38aff641eecf1d1a1dc83ce844cbc6f245b4f9b7 Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Tue, 3 Oct 2023 02:39:57 +0800 Subject: [PATCH] fix(stream): add null check. --- source/libs/stream/src/streamMeta.c | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) 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);