From 4974ac78f7bc95188d5ccf45d53c951948236a26 Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Sat, 20 May 2023 13:42:09 +0800 Subject: [PATCH] fix: fix invalid ref. --- source/libs/stream/src/streamDispatch.c | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/source/libs/stream/src/streamDispatch.c b/source/libs/stream/src/streamDispatch.c index 82b3f9a2f2..62b734da4e 100644 --- a/source/libs/stream/src/streamDispatch.c +++ b/source/libs/stream/src/streamDispatch.c @@ -526,7 +526,7 @@ int32_t streamDispatch(SStreamTask* pTask, SStreamDataBlock** pBlock) { ASSERT(pDispatchedBlock->type == STREAM_INPUT__DATA_BLOCK); - int32_t code = streamDispatchAllBlocks(pTask, *pBlock); + int32_t code = streamDispatchAllBlocks(pTask, pDispatchedBlock); if (code != TSDB_CODE_SUCCESS) { streamQueueProcessFail(pTask->outputQueue); atomic_store_8(&pTask->outputStatus, TASK_OUTPUT_STATUS__NORMAL); -- GitLab