From e3415199f5f7903d12f932d0cdb40ee8a80386f3 Mon Sep 17 00:00:00 2001
From: Haojun Liao <hjliao@taosdata.com>
Date: Sat, 27 Jul 2024 01:17:50 +0800
Subject: [PATCH] fix(stream): check return value.

---
 source/libs/executor/src/tsort.c | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/source/libs/executor/src/tsort.c b/source/libs/executor/src/tsort.c
index fe32a8939f..36c3d49810 100644
--- a/source/libs/executor/src/tsort.c
+++ b/source/libs/executor/src/tsort.c
@@ -173,6 +173,11 @@ int32_t tsortGetSortedDataBlock(const SSortHandle* pSortHandle, SSDataBlock** pB
     return TSDB_CODE_SUCCESS;
   }
 
+  if (pSortHandle->pDataBlock == NULL) {
+    *pBlock = NULL;
+    return TSDB_CODE_SUCCESS;
+  }
+
   *pBlock = createOneDataBlock(pSortHandle->pDataBlock, false);
   if (*pBlock == NULL) {
     return TSDB_CODE_OUT_OF_MEMORY;