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

Merge branch '3.0' into enh/refactorBackend

This commit is contained in:
yihaoDeng 2023-11-10 09:24:40 +08:00
parent 3e2314b09b
commit 54fe42d372
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -1724,7 +1724,8 @@ int32_t taskDbGenChkpUplaodPath__s3(STaskDbWrapper* pDb, void* bkdChkpMgt, int64
char* temp = taosMemoryCalloc(1, strlen(pDb->path)); char* temp = taosMemoryCalloc(1, strlen(pDb->path));
sprintf(temp, "%s%s%s", pDb->path, TD_DIRSEP, "tmp"); sprintf(temp, "%s%s%s", pDb->path, TD_DIRSEP, "tmp");
if (!taosDirExist(temp)) { if (taosDirExist(temp)) {
taosRemoveDir(temp);
taosMkDir(temp); taosMkDir(temp);
} }
bkdMgtGetDelta(p, pDb->idstr, chkpId, NULL, temp); bkdMgtGetDelta(p, pDb->idstr, chkpId, NULL, temp);