From 075d6880a4ca99bdcd0d237abe99fcfdf69c37e2 Mon Sep 17 00:00:00 2001 From: yukun Date: Sun, 26 Sep 2021 15:31:56 +0800 Subject: [PATCH] Fix rocksmq memleak (#8564) Signed-off-by: fishpenguin --- internal/util/rocksmq/server/rocksmq/rocksmq_impl.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go b/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go index b39bbd0fe6..0a2d62a979 100644 --- a/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go +++ b/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go @@ -634,7 +634,8 @@ func (rmq *rocksmq) Seek(topicName string, groupName string, msgID UniqueID) err opts := gorocksdb.NewDefaultReadOptions() defer opts.Destroy() - _, err = rmq.store.Get(opts, []byte(storeKey)) + val, err := rmq.store.Get(opts, []byte(storeKey)) + defer val.Free() if err != nil { log.Debug("RocksMQ: get " + storeKey + " failed") return err