fix(stream): fix memory leak.

This commit is contained in:
Haojun Liao 2024-05-22 15:13:00 +08:00
parent 009e432f2e
commit 142bc9046d
1 changed files with 1 additions and 1 deletions

View File

@ -193,7 +193,7 @@ static int32_t handleResultBlocks(SStreamTask* pTask, SArray* pRes, int32_t size
stDebug("s-task:%s dump fill-history results failed, code:%s", pTask->id.idStr, tstrerror(code));
}
} else {
taosArrayDestroy(pRes);
taosArrayDestroyEx(pRes, (FDelete)blockDataFreeRes);
}
return code;
}