add checkpoint

5adf5807 · dengyihao · 8c8b1a6d · 5adf5807
隐藏空白更改
内联并排

Showing with 3 addition and 1 deletion

source/libs/stream/src/streamBackendRocksdb.c source/libs/stream/src/streamBackendRocksdb.c +3 -1

未找到文件。
--- a/source/libs/stream/src/streamBackendRocksdb.c
+++ b/source/libs/stream/src/streamBackendRocksdb.c
@@ -185,7 +185,9 @@ _err:
 int32_t rebuildDirFromCheckpoint(const char* path, int64_t chkpId, char** dst) {
  // impl later
  int32_t code = 0;
-  char*   state = taosMemoryCalloc(1, strlen(path) + 32);
+
+  // chkpId = 0;
+  char* state = taosMemoryCalloc(1, strlen(path) + 32);
  sprintf(state, "%s/%s", path, "state");
  if (chkpId != 0) {
    char* chkp = taosMemoryCalloc(1, strlen(path) + 64);