From f77b182313650e2716d0651ad4759d8f8188e647 Mon Sep 17 00:00:00 2001
From: yihaoDeng <luomoxyz@126.com>
Date: Wed, 17 May 2023 02:01:59 +0000
Subject: [PATCH] add checkpoint

---
 source/libs/stream/src/streamMeta.c | 2 --
 1 file changed, 2 deletions(-)

diff --git a/source/libs/stream/src/streamMeta.c b/source/libs/stream/src/streamMeta.c
index de56cf24ca..939e5910e7 100644
--- a/source/libs/stream/src/streamMeta.c
+++ b/source/libs/stream/src/streamMeta.c
@@ -100,7 +100,6 @@ _err:
   if (pMeta->pTaskDb) tdbTbClose(pMeta->pTaskDb);
   if (pMeta->pCheckpointDb) tdbTbClose(pMeta->pCheckpointDb);
   if (pMeta->db) tdbClose(pMeta->db);
-  // if (pMeta->streamBackend) streamBackendCleanup(pMeta->streamBackend);
   taosMemoryFree(pMeta);
   qError("failed to open stream meta");
   return NULL;
@@ -130,7 +129,6 @@ void streamMetaClose(SStreamMeta* pMeta) {
 
   taosHashCleanup(pMeta->pTasks);
   taosRemoveRef(pMeta->streamBackendId, pMeta->streamBackendRid);
-  // streamBackendCleanup(pMeta->streamBackend);
   taosCloseRef(pMeta->streamBackendId);
   pMeta->pTaskList = taosArrayDestroy(pMeta->pTaskList);
   taosMemoryFree(pMeta->path);
-- 
GitLab