From 54fe42d3725a03d2009f9291d9378d4cff380ab9 Mon Sep 17 00:00:00 2001 From: yihaoDeng Date: Fri, 10 Nov 2023 09:24:40 +0800 Subject: [PATCH] Merge branch '3.0' into enh/refactorBackend --- source/libs/stream/src/streamBackendRocksdb.c | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/source/libs/stream/src/streamBackendRocksdb.c b/source/libs/stream/src/streamBackendRocksdb.c index 4f5076b7ff..1a29a82c11 100644 --- a/source/libs/stream/src/streamBackendRocksdb.c +++ b/source/libs/stream/src/streamBackendRocksdb.c @@ -1724,7 +1724,8 @@ int32_t taskDbGenChkpUplaodPath__s3(STaskDbWrapper* pDb, void* bkdChkpMgt, int64 char* temp = taosMemoryCalloc(1, strlen(pDb->path)); sprintf(temp, "%s%s%s", pDb->path, TD_DIRSEP, "tmp"); - if (!taosDirExist(temp)) { + if (taosDirExist(temp)) { + taosRemoveDir(temp); taosMkDir(temp); } bkdMgtGetDelta(p, pDb->idstr, chkpId, NULL, temp);