Fix memory leak in copyDataAt function

2024-04-25 07:44:31 +00:00 · 2024-04-25 07:44:31 +00:00 · d06cf49182
parent 015cd50fc8
commit d06cf49182
1 changed files with 1 additions and 0 deletions
--- a/source/libs/stream/src/streamBackendRocksdb.c
+++ b/source/libs/stream/src/streamBackendRocksdb.c
@ -2179,6 +2179,7 @@ int32_t copyDataAt(RocksdbCfInst* pSrc, STaskDbWrapper* pDst, int8_t i) {
  }

 _EXIT:
+  rocksdb_writebatch_destroy(wb);
  rocksdb_iter_destroy(pIter);
  rocksdb_readoptions_destroy(pRdOpt);
  taosMemoryFree(err);