From 9ba9bf5e8aef1530d64a6564ccf85493ed0357af Mon Sep 17 00:00:00 2001 From: Xiangyu Wang Date: Fri, 19 Mar 2021 20:20:32 +0800 Subject: [PATCH] Release memory after rocksdb.write() Signed-off-by: Xiangyu Wang --- internal/util/rocksmq/server/rocksmq/rocksmq_impl.go | 1 + 1 file changed, 1 insertion(+) diff --git a/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go b/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go index 00421f31ee..323f083141 100644 --- a/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go +++ b/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go @@ -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