Fix the completionObjects leak problem. (apache#4285)

massakam · Jul 9, 2024 · 772b162 · 772b162
1 parent fb71383
commit 772b162
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) {