(inlong) branch master updated: [INLONG-11491][SDK] Fix the judgment error of onMessageAck function in MetricSendCallBack class (#11492)

[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 ddaff247fb [INLONG-11491][SDK] Fix the judgment error of onMessageAck 
function in MetricSendCallBack class (#11492)
ddaff247fb is described below

commit ddaff247fbe939017a6b5f0042d7e6b79a63b107
Author: Goson Zhang <4675...@qq.com>
AuthorDate: Wed Nov 13 14:11:55 2024 +0800

    [INLONG-11491][SDK] Fix the judgment error of onMessageAck function in 
MetricSendCallBack class (#11492)
---
 .../org/apache/inlong/sdk/dataproxy/threads/MetricWorkerThread.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/threads/MetricWorkerThread.java
 
b/inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/threads/MetricWorkerThread.java
index ed62ccb4b6..8d79119dec 100644
--- 
a/inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/threads/MetricWorkerThread.java
+++ 
b/inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/threads/MetricWorkerThread.java
@@ -287,7 +287,7 @@ public class MetricWorkerThread extends Thread implements 
Closeable {
 
         @Override
         public void onMessageAck(SendResult result) {
-            if (!SendResult.OK.equals(result)) {
+            if (SendResult.OK.equals(result)) {
                 logger.debug("Send metric is ok!");
             } else {
                 tryToSendMetricToManager(encodeObject, this);