xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

fix stream backend convert

This commit is contained in:
yihaoDeng 2023-11-17 16:14:51 +08:00
parent ccc74ef558
commit 286413abbb
2 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
source/libs/stream/src/streamBackendRocksdb.c
View File

@ -425,6 +425,7 @@ int32_t rebuildDirFromChkp2(const char* path, char* key, int64_t chkpId, char**
code = taosMkDir(defaultPath); code = taosMkDir(defaultPath);
} }
} }
taosMemoryFree(chkpPath);
*dbPath = defaultPath; *dbPath = defaultPath;
*dbPrefixPath = prefixPath; *dbPrefixPath = prefixPath;

2
source/libs/stream/src/streamMeta.c
View File

@ -243,7 +243,7 @@ int32_t streamMetaMayCvtDbFormat(SStreamMeta* pMeta) {
int32_t streamTaskSetDb(SStreamMeta* pMeta, void* arg, char* key) { int32_t streamTaskSetDb(SStreamMeta* pMeta, void* arg, char* key) {
SStreamTask* pTask = arg; SStreamTask* pTask = arg;
int64_t chkpId = pTask->chkInfo.checkpointingId; int64_t chkpId = pTask->chkInfo.checkpointId;
taosThreadMutexLock(&pMeta->backendMutex); taosThreadMutexLock(&pMeta->backendMutex);
void** ppBackend = taosHashGet(pMeta->pTaskDbUnique, key, strlen(key)); void** ppBackend = taosHashGet(pMeta->pTaskDbUnique, key, strlen(key));