[inlong] branch master updated: [INLONG-8224][Audit] Fix audit-proxy memory leak (#8225)

[dockerzhang]

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

dockerzhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git


The following commit(s) were added to refs/heads/master by this push:
     new d08d51bb74 [INLONG-8224][Audit] Fix audit-proxy memory leak (#8225)
d08d51bb74 is described below

commit d08d51bb74fc96a2a503dd4750da891acec43dae
Author: doleyzi <43397300+dole...@users.noreply.github.com>
AuthorDate: Tue Jun 13 03:30:27 2023 -0700

    [INLONG-8224][Audit] Fix audit-proxy memory leak (#8225)
    
    Co-authored-by: doleyzi <dole...@tencent.com>
---
 .../java/org/apache/inlong/audit/source/ServerMessageHandler.java     | 4 ++++
 1 file changed, 4 insertions(+)

diff --git 
a/inlong-audit/audit-proxy/src/main/java/org/apache/inlong/audit/source/ServerMessageHandler.java
 
b/inlong-audit/audit-proxy/src/main/java/org/apache/inlong/audit/source/ServerMessageHandler.java
index 0c1c2d79a4..ef5e42de79 100644
--- 
a/inlong-audit/audit-proxy/src/main/java/org/apache/inlong/audit/source/ServerMessageHandler.java
+++ 
b/inlong-audit/audit-proxy/src/main/java/org/apache/inlong/audit/source/ServerMessageHandler.java
@@ -103,6 +103,8 @@ public class ServerMessageHandler extends 
ChannelInboundHandlerAdapter {
         } catch (Exception ex) {
             LOGGER.error("extract data error: ", ex);
             throw new IOException(ex);
+        } finally {
+            buf.release();
         }
         if (cmd == null) {
             LOGGER.warn("extract data from received msg is null");
@@ -191,6 +193,8 @@ public class ServerMessageHandler extends 
ChannelInboundHandlerAdapter {
             return;
         }
 
+        buffer.release();
+
         String msg = String.format("remote channel=%s is not writable, please 
check remote client!", channel);
         LOGGER.warn(msg);
         throw new Exception(msg);