Fix the completionObjects leak problem. (apache#4285)

sijie · Jul 12, 2024 · 4e1a30c · 4e1a30c
1 parent 6af21b1
commit 4e1a30c
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/PerChannelBookieClient.java b/bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/PerChannelBookieClient.java
@@ -1206,6 +1206,7 @@ private void writeAndFlush(final Channel channel,
                         }
                     } else {
                         nettyOpLogger.registerFailedEvent(MathUtils.elapsedNanos(startTime), TimeUnit.NANOSECONDS);
+                        errorOut(key);
                     }
                 } finally {
                     if (cleanupActionAfterWrite != null) {