(rocketmq) branch develop updated: [ISSUE #9418] Fix ColumnFamilyHandle not close in PopConsumerRocksdbStore (#9420)

[lizhimin]

This is an automated email from the ASF dual-hosted git repository.

lizhimin pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


The following commit(s) were added to refs/heads/develop by this push:
     new c9ea74962f [ISSUE #9418] Fix ColumnFamilyHandle not close in 
PopConsumerRocksdbStore (#9420)
c9ea74962f is described below

commit c9ea74962f4796be0b1137b120ee2106f8c732ff
Author: lizhimins <707364...@qq.com>
AuthorDate: Wed May 21 18:59:27 2025 +0800

    [ISSUE #9418] Fix ColumnFamilyHandle not close in PopConsumerRocksdbStore 
(#9420)
---
 .../java/org/apache/rocketmq/broker/pop/PopConsumerRocksdbStore.java  | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerRocksdbStore.java
 
b/broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerRocksdbStore.java
index 7ab276a418..135b914674 100644
--- 
a/broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerRocksdbStore.java
+++ 
b/broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerRocksdbStore.java
@@ -164,8 +164,8 @@ public class PopConsumerRocksdbStore extends 
AbstractRocksDBStorage implements P
         if (this.deleteOptions != null) {
             this.deleteOptions.close();
         }
-        if (this.defaultCFHandle != null) {
-            this.defaultCFHandle.close();
+        if (this.columnFamilyHandle != null) {
+            this.columnFamilyHandle.close();
         }
     }
 }