fix(stream): fix memory leak.

2024-04-26 17:06:15 +08:00 · 2024-04-26 17:06:15 +08:00 · 6d06188b9f
parent b1b3246066
commit 6d06188b9f
1 changed files with 1 additions and 0 deletions
--- a/source/dnode/vnode/src/tq/tqSink.c
+++ b/source/dnode/vnode/src/tq/tqSink.c
@ -485,6 +485,7 @@ SVCreateTbReq* buildAutoCreateTableReq(const char* stbFullName, int64_t suid, in

 int32_t doPutIntoCache(SSHashObj* pSinkTableMap, STableSinkInfo* pTableSinkInfo, uint64_t groupId, const char* id) {
  if (tSimpleHashGetSize(pSinkTableMap) > MAX_CACHE_TABLE_INFO_NUM) {
+    taosMemoryFreeClear(pTableSinkInfo);  // too many items, failed to cache it
    return TSDB_CODE_FAILED;
  }