fix(query): fix memory leak.

This commit is contained in:
Haojun Liao 2022-06-24 22:54:06 +08:00
parent cebecb9ae6
commit 6c49aecb70
1 changed files with 2 additions and 0 deletions

View File

@ -1022,6 +1022,8 @@ static SSDataBlock* doStreamBlockScan(SOperatorInfo* pOperator) {
}
}
taosArrayDestroy(block.pDataBlock);
if (pInfo->pRes->pDataBlock == NULL) {
// TODO add log
pOperator->status = OP_EXEC_DONE;