From 862e7c8e3681fb1aa079418acb173f0f0b9e2731 Mon Sep 17 00:00:00 2001 From: Cary Xu Date: Fri, 5 Aug 2022 09:47:50 +0800 Subject: [PATCH] fix: conditional comparison --- source/libs/executor/src/executor.c | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/source/libs/executor/src/executor.c b/source/libs/executor/src/executor.c index 2d5bf357b0..84b08bb821 100644 --- a/source/libs/executor/src/executor.c +++ b/source/libs/executor/src/executor.c @@ -103,7 +103,7 @@ void tdCleanupStreamInputDataBlock(qTaskInfo_t tinfo) { if (pOptrInfo->operatorType == QUERY_NODE_PHYSICAL_PLAN_STREAM_SCAN) { SStreamScanInfo* pInfo = pOptrInfo->info; - if (pInfo->blockType = STREAM_INPUT__DATA_BLOCK) { + if (pInfo->blockType == STREAM_INPUT__DATA_BLOCK) { for (int32_t i = 0; i < taosArrayGetSize(pInfo->pBlockLists); ++i) { SSDataBlock* p = *(SSDataBlock**)taosArrayGet(pInfo->pBlockLists, i); taosArrayDestroy(p->pDataBlock);