From 6a3bbccda95a32572b708c9fe1f4e7a18b64f3ad Mon Sep 17 00:00:00 2001
From: 54liuyao <54liuyao>
Date: Thu, 20 Jun 2024 10:23:44 +0800
Subject: [PATCH] adj par tbname cache

---
 source/libs/stream/src/streamState.c | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/source/libs/stream/src/streamState.c b/source/libs/stream/src/streamState.c
index 23100362ac..cac0e8b662 100644
--- a/source/libs/stream/src/streamState.c
+++ b/source/libs/stream/src/streamState.c
@@ -1096,7 +1096,9 @@ _end:
 int32_t streamStatePutParName(SStreamState* pState, int64_t groupId, const char tbname[TSDB_TABLE_NAME_LEN]) {
 #ifdef USE_ROCKSDB
   if (tSimpleHashGet(pState->parNameMap, &groupId, sizeof(int64_t)) == NULL) {
-    tSimpleHashPut(pState->parNameMap, &groupId, sizeof(int64_t), tbname, TSDB_TABLE_NAME_LEN);
+    if (tSimpleHashGetSize(pState->parNameMap) < MAX_TABLE_NAME_NUM) {
+      tSimpleHashPut(pState->parNameMap, &groupId, sizeof(int64_t), tbname, TSDB_TABLE_NAME_LEN);
+    }
     streamStatePutParName_rocksdb(pState, groupId, tbname);
   }
   return TSDB_CODE_SUCCESS;
@@ -1114,7 +1116,7 @@ int32_t streamStateGetParName(SStreamState* pState, int64_t groupId, void** pVal
       return TSDB_CODE_FAILED;
     }
     int32_t code = streamStateGetParName_rocksdb(pState, groupId, pVal);
-    if (code == TSDB_CODE_SUCCESS) {
+    if (code == TSDB_CODE_SUCCESS && tSimpleHashGetSize(pState->parNameMap) < MAX_TABLE_NAME_NUM) {
       tSimpleHashPut(pState->parNameMap, &groupId, sizeof(int64_t), *pVal, TSDB_TABLE_NAME_LEN);
     }
     return code;