fix: memory leak
This commit is contained in:
parent
14d4a81e75
commit
d7f8757844
|
@ -515,6 +515,12 @@ static void mergeJoinDestroyTSRangeCtx(SJoinOperatorInfo* pJoinInfo, SArray* lef
|
||||||
taosArrayDestroy(rightRowLocations);
|
taosArrayDestroy(rightRowLocations);
|
||||||
}
|
}
|
||||||
if (rightUseBuildTable) {
|
if (rightUseBuildTable) {
|
||||||
|
void* p = NULL;
|
||||||
|
int32_t iter = 0;
|
||||||
|
while ((p = tSimpleHashIterate(pJoinInfo->rightBuildTable, p, &iter)) != NULL) {
|
||||||
|
SArray* rows = (*(SArray**)p);
|
||||||
|
taosArrayDestroy(rows);
|
||||||
|
}
|
||||||
tSimpleHashClear(pJoinInfo->rightBuildTable);
|
tSimpleHashClear(pJoinInfo->rightBuildTable);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue