diff --git a/source/libs/stream/src/streamBackendRocksdb.c b/source/libs/stream/src/streamBackendRocksdb.c index a29ac67cfe..99bcfd744f 100644 --- a/source/libs/stream/src/streamBackendRocksdb.c +++ b/source/libs/stream/src/streamBackendRocksdb.c @@ -398,6 +398,7 @@ int32_t delObsoleteCheckpoint(void* arg, const char* path) { taosRemoveDir(tbuf); } } + taosArrayDestroy(checkpointDel); return 0; } int32_t streamBackendDoCheckpoint(void* arg, const char* path) {