From 0f5f21ba09ede0fe0a55fe1f09ba192fb42371d1 Mon Sep 17 00:00:00 2001
From: Haojun Liao <hjliao@taosdata.com>
Date: Fri, 22 Sep 2023 16:05:12 +0800
Subject: [PATCH] fix(stream): fix invalid read.

---
 source/libs/stream/src/streamTask.c | 14 +++++++-------
 1 file changed, 7 insertions(+), 7 deletions(-)

diff --git a/source/libs/stream/src/streamTask.c b/source/libs/stream/src/streamTask.c
index 34d1f7a9c9..56f97c565a 100644
--- a/source/libs/stream/src/streamTask.c
+++ b/source/libs/stream/src/streamTask.c
@@ -342,6 +342,13 @@ void tFreeStreamTask(SStreamTask* pTask) {
     walCloseReader(pTask->exec.pWalReader);
   }
 
+  pTask->pReadyMsgList = taosArrayDestroy(pTask->pReadyMsgList);
+  if (pTask->msgInfo.pData != NULL) {
+    destroyDispatchMsg(pTask->msgInfo.pData, getNumOfDispatchBranch(pTask));
+    pTask->msgInfo.pData = NULL;
+    pTask->msgInfo.dispatchMsgType = 0;
+  }
+
   if (pTask->outputInfo.type == TASK_OUTPUT__TABLE) {
     tDeleteSchemaWrapper(pTask->tbSink.pSchemaWrapper);
     taosMemoryFree(pTask->tbSink.pTSchema);
@@ -356,13 +363,6 @@ void tFreeStreamTask(SStreamTask* pTask) {
     streamStateClose(pTask->pState, status == TASK_STATUS__DROPPING);
   }
 
-  pTask->pReadyMsgList = taosArrayDestroy(pTask->pReadyMsgList);
-  if (pTask->msgInfo.pData != NULL) {
-    destroyDispatchMsg(pTask->msgInfo.pData, getNumOfDispatchBranch(pTask));
-    pTask->msgInfo.pData = NULL;
-    pTask->msgInfo.dispatchMsgType = 0;
-  }
-
   if (pTask->id.idStr != NULL) {
     taosMemoryFree((void*)pTask->id.idStr);
   }