From 0471afb840f5a631c5a510c9a3631c491437d63f Mon Sep 17 00:00:00 2001
From: 54liuyao <54liuyao>
Date: Thu, 20 Jun 2024 13:25:36 +0800
Subject: [PATCH] adj sream tbname cache

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

diff --git a/source/libs/stream/src/streamState.c b/source/libs/stream/src/streamState.c
index 31bf1b67a4..a817070d5b 100644
--- a/source/libs/stream/src/streamState.c
+++ b/source/libs/stream/src/streamState.c
@@ -1112,12 +1112,11 @@ int32_t streamStateGetParName(SStreamState* pState, int64_t groupId, void** pVal
 #ifdef USE_ROCKSDB
   void* pStr = tSimpleHashGet(pState->parNameMap, &groupId, sizeof(int64_t));
   if (!pStr) {
-    bool isFull = (tSimpleHashGetSize(pState->parNameMap) >= MAX_TABLE_NAME_NUM);
-    if (onlyCache && isFull) {
+    if (onlyCache && tSimpleHashGetSize(pState->parNameMap) < MAX_TABLE_NAME_NUM) {
       return TSDB_CODE_FAILED;
     }
     int32_t code = streamStateGetParName_rocksdb(pState, groupId, pVal);
-    if (code == TSDB_CODE_SUCCESS && isFull) {
+    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;