From 286413abbb5c1bf84d127114cb3b0aebf034a243 Mon Sep 17 00:00:00 2001
From: yihaoDeng <yhdeng@taosdata.com>
Date: Fri, 17 Nov 2023 16:14:51 +0800
Subject: [PATCH] fix stream backend convert

---
 source/libs/stream/src/streamBackendRocksdb.c | 1 +
 source/libs/stream/src/streamMeta.c           | 2 +-
 2 files changed, 2 insertions(+), 1 deletion(-)

diff --git a/source/libs/stream/src/streamBackendRocksdb.c b/source/libs/stream/src/streamBackendRocksdb.c
index c91bb2a393..d2aab7459b 100644
--- a/source/libs/stream/src/streamBackendRocksdb.c
+++ b/source/libs/stream/src/streamBackendRocksdb.c
@@ -425,6 +425,7 @@ int32_t rebuildDirFromChkp2(const char* path, char* key, int64_t chkpId, char**
       code = taosMkDir(defaultPath);
     }
   }
+  taosMemoryFree(chkpPath);
 
   *dbPath = defaultPath;
   *dbPrefixPath = prefixPath;
diff --git a/source/libs/stream/src/streamMeta.c b/source/libs/stream/src/streamMeta.c
index afc7512cf8..138759c179 100644
--- a/source/libs/stream/src/streamMeta.c
+++ b/source/libs/stream/src/streamMeta.c
@@ -243,7 +243,7 @@ int32_t streamMetaMayCvtDbFormat(SStreamMeta* pMeta) {
 int32_t streamTaskSetDb(SStreamMeta* pMeta, void* arg, char* key) {
   SStreamTask* pTask = arg;
 
-  int64_t chkpId = pTask->chkInfo.checkpointingId;
+  int64_t chkpId = pTask->chkInfo.checkpointId;
 
   taosThreadMutexLock(&pMeta->backendMutex);
   void** ppBackend = taosHashGet(pMeta->pTaskDbUnique, key, strlen(key));