Fix cache entry

apache · Aug 4, 2022 · 8a5e1c0 · 8a5e1c0
1 parent f6d0bd8
commit 8a5e1c0
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/...d-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/cache/SharedEntryCacheImpl.java b/...d-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/cache/SharedEntryCacheImpl.java
@@ -173,8 +173,10 @@ private void asyncReadEntry0(ReadHandle lh, PositionImpl position, AsyncCallback
         EntryImpl cachedEntry = entryCacheManager.get(position.getLedgerId(), position.getEntryId());
 
         if (cachedEntry != null) {
-            entryCacheManager.getFactoryMBean().recordCacheHit(cachedEntry.getLength());
-            callback.readEntryComplete(cachedEntry, ctx);
+            EntryImpl entry = EntryImpl.create(cachedEntry);
+            cachedEntry.release();
+            entryCacheManager.getFactoryMBean().recordCacheHit(entry.getLength());
+            callback.readEntryComplete(entry, ctx);
         } else {
             lh.readAsync(position.getEntryId(), position.getEntryId()).thenAcceptAsync(
                     ledgerEntries -> {