support reopen stream state

a336a7b1 · dengyihao · a619b8f5 · a336a7b1
显示空白变更内容
内联并排

Showing with 4 addition and 0 deletion

source/libs/stream/src/streamBackendRocksdb.c source/libs/stream/src/streamBackendRocksdb.c +4 -0

未找到文件。
--- 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;