Skip to content
Snippets Groups Projects
Commit 9ba9bf5e authored by Xiangyu Wang's avatar Xiangyu Wang Committed by yefu.chen
Browse files

Release memory after rocksdb.write()


Signed-off-by: default avatarXiangyu Wang <xiangyu.wang@zilliz.com>
parent 22807911
No related branches found
No related tags found
No related merge requests found
......@@ -203,6 +203,7 @@ func (rmq *rocksmq) Produce(topicName string, messages []ProducerMessage) error
}
err = rmq.store.Write(gorocksdb.NewDefaultWriteOptions(), batch)
batch.Destroy()
if err != nil {
log.Debug("RocksMQ: write batch failed")
return err
......
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment