fix(stream): fix syntax error.

This commit is contained in:
Haojun Liao 2024-07-19 11:49:05 +08:00
parent 144855ef83
commit c36d6d44cd
1 changed files with 2 additions and 1 deletions

View File

@ -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;