[INLONG-11491][SDK] Fix the judgment error of onMessageAck function i…

…n MetricSendCallBack class (#11492)
apache · Nov 13, 2024 · ddaff24 · ddaff24
1 parent 28c3c6b
commit ddaff24
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...taproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/threads/MetricWorkerThread.java b/...taproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/threads/MetricWorkerThread.java
@@ -287,7 +287,7 @@ public int getRetryCount() {
 
         @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);