RATIS-2065. Avoid the out-of-heap memory OOM phenomenon of frequent c…

…reation and deletion of Raft group scenarios. (#1071)
apache · Apr 29, 2024 · 1fe59e0 · 1fe59e0
1 parent b0ec114
commit 1fe59e0
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/...erver/src/main/java/org/apache/ratis/server/raftlog/segmented/SegmentedRaftLogWorker.java b/...erver/src/main/java/org/apache/ratis/server/raftlog/segmented/SegmentedRaftLogWorker.java
@@ -38,6 +38,7 @@
 import org.apache.ratis.statemachine.StateMachine;
 import org.apache.ratis.statemachine.StateMachine.DataStream;
 import org.apache.ratis.statemachine.TransactionContext;
+import org.apache.ratis.thirdparty.io.netty.util.internal.PlatformDependent;
 import org.apache.ratis.util.*;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -242,6 +243,7 @@ void close() {
     Optional.ofNullable(flushExecutor).ifPresent(ExecutorService::shutdown);
     ConcurrentUtils.shutdownAndWait(TimeDuration.ONE_SECOND.multiply(3),
         workerThreadExecutor, timeout -> LOG.warn("{}: shutdown timeout in " + timeout, name));
+    PlatformDependent.freeDirectBuffer(writeBuffer);
     IOUtils.cleanup(LOG, out);
     LOG.info("{} close()", name);
   }