From 50b59ad936153fb6d97c4493117aca6763950129 Mon Sep 17 00:00:00 2001
From: Haojun Liao <hjliao@taosdata.com>
Date: Fri, 26 Jan 2024 16:08:01 +0800
Subject: [PATCH] fix(stream): add null ptr check.

---
 source/dnode/mnode/impl/src/mndStream.c | 9 ++++++++-
 1 file changed, 8 insertions(+), 1 deletion(-)

diff --git a/source/dnode/mnode/impl/src/mndStream.c b/source/dnode/mnode/impl/src/mndStream.c
index 5528be3f0f..3547d61c3d 100644
--- a/source/dnode/mnode/impl/src/mndStream.c
+++ b/source/dnode/mnode/impl/src/mndStream.c
@@ -2203,8 +2203,15 @@ int32_t mndProcessStreamReqCheckpoint(SRpcMsg *pReq) {
   taosThreadMutexLock(&execInfo.lock);
 
   SStreamObj *pStream = mndGetStreamObj(pMnode, req.streamId);
-  int32_t     numOfTasks = mndGetNumOfStreamTasks(pStream);
+  if (pStream == NULL) {
+    mError("failed to find the stream:0x%"PRIx64" not handle the checkpoint req", req.streamId);
+    terrno = TSDB_CODE_MND_STREAM_NOT_EXIST;
+    taosThreadMutexUnlock(&execInfo.lock);
 
+    return -1;
+  }
+
+  int32_t  numOfTasks = mndGetNumOfStreamTasks(pStream);
   SArray **pReqTaskList = (SArray**)taosHashGet(execInfo.pTransferStateStreams, &req.streamId, sizeof(req.streamId));
   if (pReqTaskList == NULL) {
     SArray *pList = taosArrayInit(4, sizeof(int32_t));