fix(stream): fix memory leak.

This commit is contained in:
Haojun Liao 2024-02-01 13:04:26 +08:00
parent 4088e1cbff
commit ac2d8f4ca8
1 changed files with 2 additions and 0 deletions

View File

@ -971,6 +971,8 @@ void postSubQueryFetchCb(void* param, TAOS_RES* res, int32_t rowNum) {
tscError("0x%" PRIx64 ", next req ref 0x%" PRIx64 " is not there, reqId:0x%" PRIx64, pRequest->self,
pRequest->relation.nextRefId, pRequest->requestId);
}
blockDataDestroy(pBlock);
}
void handlePostSubQuery(SSqlCallbackWrapper* pWrapper) {