fix(stream/state): switch tdb rollback on to restore from journals

f4a60a43 · Minglei Jin · 25f7ac79 · f4a60a43
隐藏空白更改
内联并排

Showing with 1 addition and 1 deletion

source/libs/stream/src/streamState.c source/libs/stream/src/streamState.c +1 -1

未找到文件。
--- a/source/libs/stream/src/streamState.c
+++ b/source/libs/stream/src/streamState.c
@@ -128,7 +128,7 @@ SStreamState* streamStateOpen(char* path, SStreamTask* pTask, bool specPath, int
    memset(statePath, 0, 1024);
    tstrncpy(statePath, path, 1024);
  }
-  if (tdbOpen(statePath, szPage, pages, &pState->pTdbState->db, 0) < 0) {
+  if (tdbOpen(statePath, szPage, pages, &pState->pTdbState->db, 1) < 0) {
    goto _err;
  }