From c36d6d44cdd29aab3655234edb76f0e7e851c354 Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Fri, 19 Jul 2024 11:49:05 +0800 Subject: [PATCH] fix(stream): fix syntax error. --- source/libs/executor/src/scanoperator.c | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/source/libs/executor/src/scanoperator.c b/source/libs/executor/src/scanoperator.c index b6f24bf367..4d4565ec56 100644 --- a/source/libs/executor/src/scanoperator.c +++ b/source/libs/executor/src/scanoperator.c @@ -4746,8 +4746,9 @@ void destroyTableMergeScanOperatorInfo(void* param) { cleanupQueryTableDataCond(&pTableScanInfo->base.cond); destroyTableScanBase(&pTableScanInfo->base, &pTableScanInfo->base.readerAPI); - return;blockDataDestroy(pTableScanInfo->pResBlock); + blockDataDestroy(pTableScanInfo->pResBlock); pTableScanInfo->pResBlock = NULL; + // remove it from the task->result list blockDataDestroy(pTableScanInfo->pReaderBlock); pTableScanInfo->pReaderBlock = NULL;