From 4a99bdc2b01eb88be26fea2963c7ccce98dea73d Mon Sep 17 00:00:00 2001 From: yihaoDeng Date: Thu, 9 Nov 2023 20:27:30 +0800 Subject: [PATCH] support s3 --- source/libs/stream/src/streamBackendRocksdb.c | 15 ++++++++------- 1 file changed, 8 insertions(+), 7 deletions(-) diff --git a/source/libs/stream/src/streamBackendRocksdb.c b/source/libs/stream/src/streamBackendRocksdb.c index 253c18467e..4f5076b7ff 100644 --- a/source/libs/stream/src/streamBackendRocksdb.c +++ b/source/libs/stream/src/streamBackendRocksdb.c @@ -1738,9 +1738,9 @@ int32_t taskDbGenChkpUploadPath(void* arg, void* mgt, int64_t chkpId, int8_t typ UPLOAD_TYPE utype = type; if (utype == UPLOAD_RSYNC) { - return taskDbGenChkpUplaodPath__rsync(pDb,chkpId, path); + return taskDbGenChkpUplaodPath__rsync(pDb, chkpId, path); } else if (utype == UPLOAD_S3) { - return taskDbGenChkpUplaodPath__s3(pDb,mgt, chkpId, path); + return taskDbGenChkpUplaodPath__s3(pDb, mgt, chkpId, path); } return -1; } @@ -3633,14 +3633,15 @@ int32_t bkdMgtGetDelta(SBkdMgt* bm, char* taskId, int64_t chkpId, SArray* list, taosHashPut(bm->pDbChkpTbl, taskId, strlen(taskId), &p, sizeof(void*)); taosMemoryFree(taskPath); + pChkp = p; + + code = dbChkpDumpTo(pChkp, dname); + taosThreadRwlockUnlock(&bm->rwLock); + return code; } - taosThreadRwlockUnlock(&bm->rwLock); - code = dbChkpGetDelta(pChkp, chkpId, list); - - code = dbChkpDumpTo(pChkp, dname); - + taosThreadRwlockUnlock(&bm->rwLock); return code; }