[TD-2169]<fix>: fix memory leaks in group by query processing.

7090b3fe · Haojun Liao · 0fe731af · 7090b3fe
隐藏空白更改
内联并排

Showing with 6 addition and 2 deletion

src/query/src/qExecutor.c src/query/src/qExecutor.c +6 -2

未找到文件。
--- a/src/query/src/qExecutor.c
+++ b/src/query/src/qExecutor.c
@@ -1372,8 +1372,12 @@ static int32_t setGroupResultOutputBuf(SQueryRuntimeEnv *pRuntimeEnv, char *pDat
  }
  if (type == TSDB_DATA_TYPE_BINARY || type == TSDB_DATA_TYPE_NCHAR) {
-    pResultRow->key = malloc(varDataTLen(pData));
+    if (pResultRow->key == NULL) {
-    varDataCopy(pResultRow->key, pData);
+      pResultRow->key = malloc(varDataTLen(pData));
+      varDataCopy(pResultRow->key, pData);
+    } else {
+      assert(memcmp(pResultRow->key, pData, varDataTLen(pData)) == 0);
+    }
  } else {
    pResultRow->win.skey = v;
    pResultRow->win.ekey = v;