From 5adf5807645b5d66d78b3f6d5d4b5740a2df08ad Mon Sep 17 00:00:00 2001 From: yihaoDeng Date: Mon, 17 Jul 2023 03:44:06 +0000 Subject: [PATCH] add checkpoint --- source/libs/stream/src/streamBackendRocksdb.c | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/source/libs/stream/src/streamBackendRocksdb.c b/source/libs/stream/src/streamBackendRocksdb.c index 55b53552d4..597d1bd4f2 100644 --- 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);