fix invalid cmp

2268114c · yihaoDeng · 55f1d464 · 2268114c
隐藏空白更改
内联并排

Showing with 4 addition and 4 deletion

source/libs/stream/src/streamBackendRocksdb.c source/libs/stream/src/streamBackendRocksdb.c +4 -4

未找到文件。
--- 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++) {
+  for (int i = 0; i < taosArrayGetSize(refs); i++) {
-  //   int64_t id = *(int64_t*)taosArrayGet(refs, i);
+    int64_t id = *(int64_t*)taosArrayGet(refs, i);
-  //   taosReleaseRef(streamBackendCfWrapperId, id);
+    taosReleaseRef(streamBackendCfWrapperId, id);
-  // }
+  }
  if (code == 0) {
    taosWLockLatch(&pMeta->chkpDirLock);
    taosArrayPush(pMeta->chkpSaved, &checkpointId);