[inlong] branch release-1.3.0 updated: [INLONG-5963][Audit] Solve the sdk memory leak problem (#5965)

[dockerzhang]

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

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


The following commit(s) were added to refs/heads/release-1.3.0 by this push:
     new 30d6eb901 [INLONG-5963][Audit] Solve the sdk memory leak problem 
(#5965)
30d6eb901 is described below

commit 30d6eb901ffae9bbcde051e2b182b69c00a50af3
Author: doleyzi <43397300+dole...@users.noreply.github.com>
AuthorDate: Tue Sep 20 20:43:13 2022 +0800

    [INLONG-5963][Audit] Solve the sdk memory leak problem (#5965)
    
    Co-authored-by: doleyzi <dole...@tencent.com>
---
 .../src/main/java/org/apache/inlong/audit/send/SenderGroup.java       | 4 ++++
 1 file changed, 4 insertions(+)

diff --git 
a/inlong-audit/audit-sdk/src/main/java/org/apache/inlong/audit/send/SenderGroup.java
 
b/inlong-audit/audit-sdk/src/main/java/org/apache/inlong/audit/send/SenderGroup.java
index 7598fa654..33b12e58d 100644
--- 
a/inlong-audit/audit-sdk/src/main/java/org/apache/inlong/audit/send/SenderGroup.java
+++ 
b/inlong-audit/audit-sdk/src/main/java/org/apache/inlong/audit/send/SenderGroup.java
@@ -79,6 +79,7 @@ public class SenderGroup {
         try {
             if (channels.size() <= 0) {
                 logger.error("channels is empty");
+                dataBuf.release();
                 return new SenderResult("channels is empty", 0, false);
             }
             boolean isOk = false;
@@ -110,6 +111,7 @@ public class SenderGroup {
             }
             if (channel == null) {
                 logger.error("can not get a channel");
+                dataBuf.release();
                 return new SenderResult("can not get a channel", 0, false);
             }
 
@@ -122,6 +124,8 @@ public class SenderGroup {
                     }
                     t = 
channel.getChannel().writeAndFlush(dataBuf).sync().await();
                 }
+            } else {
+                dataBuf.release();
             }
             return new SenderResult(channel.getIpPort().ip, 
channel.getIpPort().port, t.isSuccess());
         } catch (Throwable ex) {