fix(executor): Batch Partition Operator memory leak

a1c4572a · 54liuyao · d53ab62f · a1c4572a
隐藏空白更改
内联并排

Showing with 4 addition and 3 deletion

source/libs/executor/src/groupoperator.c source/libs/executor/src/groupoperator.c +4 -3

未找到文件。
--- a/source/libs/executor/src/groupoperator.c
+++ b/source/libs/executor/src/groupoperator.c
@@ -621,9 +621,10 @@ int32_t* setupColumnOffset(const SSDataBlock* pBlock, int32_t rowCapacity) {
 }
 static void clearPartitionOperator(SPartitionOperatorInfo* pInfo) {
-  void* ite = NULL;
+  int32_t size = taosArrayGetSize(pInfo->sortedGroupArray);
-  while ((ite = taosHashIterate(pInfo->pGroupSet, ite)) != NULL) {
+  for (int32_t i = 0; i < size; i++) {
-    taosArrayDestroy(((SDataGroupInfo*)ite)->pPageList);
+    SDataGroupInfo* pGp = taosArrayGet(pInfo->sortedGroupArray, i);
+    taosArrayDestroy(pGp->pPageList);
  }
  taosArrayClear(pInfo->sortedGroupArray);
  clearDiskbasedBuf(pInfo->pBuf);