(inlong) branch master updated: [INLONG-11715][SDK] Optimize metric report content (#11716)

[gosonzhang]

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

gosonzhang 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 2776a98fb1 [INLONG-11715][SDK] Optimize metric report content (#11716)
2776a98fb1 is described below

commit 2776a98fb13636bf30ab5be40c486b84f8f1978f
Author: Goson Zhang <4675...@qq.com>
AuthorDate: Thu Feb 6 08:13:46 2025 +0800

    [INLONG-11715][SDK] Optimize metric report content (#11716)
    
    Co-authored-by: gosonzhang <gosonzh...@tencent.com>
---
 .../java/org/apache/inlong/sdk/dataproxy/metric/MetaSyncInfo.java  | 2 +-
 .../org/apache/inlong/sdk/dataproxy/metric/MetricDataHolder.java   | 7 +++++--
 .../java/org/apache/inlong/sdk/dataproxy/metric/TimeCostInfo.java  | 2 +-
 .../java/org/apache/inlong/sdk/dataproxy/metric/TrafficInfo.java   | 2 +-
 4 files changed, 8 insertions(+), 5 deletions(-)

diff --git 
a/inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/metric/MetaSyncInfo.java
 
b/inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/metric/MetaSyncInfo.java
index d026799b1e..2539c7ae53 100644
--- 
a/inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/metric/MetaSyncInfo.java
+++ 
b/inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/metric/MetaSyncInfo.java
@@ -51,7 +51,7 @@ public class MetaSyncInfo {
             strBuff.append("}");
         } else {
             long curCnt = 0;
-            strBuff.append("\"metaSync\":{\"errT\":{");
+            strBuff.append("\"mSync\":{\"errT\":{");
             for (Map.Entry<Integer, LongAdder> entry : syncErrInfo.entrySet()) 
{
                 if (curCnt++ > 0) {
                     strBuff.append(",");
diff --git 
a/inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/metric/MetricDataHolder.java
 
b/inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/metric/MetricDataHolder.java
index b744ff22b2..222b8099b8 100644
--- 
a/inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/metric/MetricDataHolder.java
+++ 
b/inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/metric/MetricDataHolder.java
@@ -327,10 +327,13 @@ public class MetricDataHolder implements Runnable {
             TcpMsgSenderConfig tcpConfig = (TcpMsgSenderConfig) 
sender.getConfigure();
             
strBuff.append(",\"mT\":").append(tcpConfig.getSdkMsgType().getValue())
                     
.append(",\"comp\":").append(tcpConfig.isEnableDataCompress())
+                    
.append(",\"mCLen\":").append(tcpConfig.getMinCompEnableLength())
+                    
.append(",\"lfSep\":").append(tcpConfig.isSeparateEventByLF())
                     
.append(",\"nWk\":").append(tcpConfig.getNettyWorkerThreadNum())
                     .append(",\"sB\":").append(tcpConfig.getSendBufferSize())
-                    
.append(",\"rTout\":").append(tcpConfig.getRequestTimeoutMs())
-                    
.append(",\"reqOut\":").append(tcpConfig.getRequestTimeoutMs())
+                    .append(",\"rB\":").append(tcpConfig.getRcvBufferSize())
+                    
.append(",\"cOut\":").append(tcpConfig.getConnectTimeoutMs())
+                    
.append(",\"rOut\":").append(tcpConfig.getRequestTimeoutMs())
                     
.append(",\"syncOut\":").append(tcpConfig.getMaxAllowedSyncMsgTimeoutCnt());
         } else {
             HttpMsgSenderConfig httpConfig = (HttpMsgSenderConfig) 
sender.getConfigure();
diff --git 
a/inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/metric/TimeCostInfo.java
 
b/inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/metric/TimeCostInfo.java
index 50c2e1a6bc..1bd33306a1 100644
--- 
a/inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/metric/TimeCostInfo.java
+++ 
b/inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/metric/TimeCostInfo.java
@@ -73,7 +73,7 @@ public class TimeCostInfo {
         long curTotalCnt = totalCnt.sumThenReset();
         if (curTotalCnt == 0) {
             strBuff.append("\"").append(name)
-                    
.append("\":{\"bucketT\":{},\"min\":0,\"max\":0,\"avgT\":0,\"cnt\":0}");
+                    
.append("\":{\"bucketT\":{},\"min\":0,\"max\":0,\"avgT\":0}");
         } else {
             long bucketCnt = 0;
             strBuff.append("\"").append(name).append("\":{\"bucketT\":{");
diff --git 
a/inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/metric/TrafficInfo.java
 
b/inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/metric/TrafficInfo.java
index 2d242ba064..2622c47cef 100644
--- 
a/inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/metric/TrafficInfo.java
+++ 
b/inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/metric/TrafficInfo.java
@@ -76,7 +76,7 @@ public class TrafficInfo {
         }
         strBuff.append("\",\"sPkg\":").append(sendPkgCount.sumThenReset())
                 .append(",\"sMsg\":").append(sendMsgCount.sumThenReset())
-                .append(",\"fMsg\":").append(failedPgkCount.sumThenReset())
+                .append(",\"fPkg\":").append(failedPgkCount.sumThenReset())
                 .append(",\"fMsg\":").append(failedMsgCount.sumThenReset())
                 .append(",");
         this.sendCostMs.getAndResetValue(strBuff);