From a336a7b1a4d3e9da279c0533f96bbd1532b0a437 Mon Sep 17 00:00:00 2001 From: yihaoDeng Date: Wed, 9 Aug 2023 09:06:22 +0000 Subject: [PATCH] support reopen stream state --- source/libs/stream/src/streamBackendRocksdb.c | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/source/libs/stream/src/streamBackendRocksdb.c b/source/libs/stream/src/streamBackendRocksdb.c index 529b29153d..a724e90866 100644 --- a/source/libs/stream/src/streamBackendRocksdb.c +++ b/source/libs/stream/src/streamBackendRocksdb.c @@ -277,6 +277,10 @@ int32_t backendManagerDumpTo(SBackendManager* bm, char* dname) { sprintf(srcDir, "%s%s%s%" PRId64 "", bm->path, TD_DIRSEP, "checkpoint", bm->curChkpId); sprintf(dstDir, "%s%s%s", bm->path, TD_DIRSEP, dname); + if (!taosDirExist(srcDir)) { + return 0; + } + code = taosMkDir(dstDir); if (code != 0) { return code;