From 2268114c4a07bb23690569fca5cebd90f18fea4f Mon Sep 17 00:00:00 2001
From: yihaoDeng <cyang@taosdata.com>
Date: Tue, 22 Aug 2023 09:10:48 +0800
Subject: [PATCH] fix invalid cmp

---
 source/libs/stream/src/streamBackendRocksdb.c | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/source/libs/stream/src/streamBackendRocksdb.c b/source/libs/stream/src/streamBackendRocksdb.c
index 3cf1d34a7e..ef42d303fd 100644
--- a/source/libs/stream/src/streamBackendRocksdb.c
+++ b/source/libs/stream/src/streamBackendRocksdb.c
@@ -916,10 +916,10 @@ int32_t streamBackendDoCheckpoint(void* arg, uint64_t checkpointId) {
     qError("stream backend:%p failed to flush db at:%s", pHandle, pChkpIdDir);
   }
   // release all ref to cfWrapper;
-  // for (int i = 0; i < taosArrayGetSize(refs); i++) {
-  //   int64_t id = *(int64_t*)taosArrayGet(refs, i);
-  //   taosReleaseRef(streamBackendCfWrapperId, id);
-  // }
+  for (int i = 0; i < taosArrayGetSize(refs); i++) {
+    int64_t id = *(int64_t*)taosArrayGet(refs, i);
+    taosReleaseRef(streamBackendCfWrapperId, id);
+  }
   if (code == 0) {
     taosWLockLatch(&pMeta->chkpDirLock);
     taosArrayPush(pMeta->chkpSaved, &checkpointId);