From ddaff247fbe939017a6b5f0042d7e6b79a63b107 Mon Sep 17 00:00:00 2001 From: Goson Zhang <4675739@qq.com> Date: Wed, 13 Nov 2024 14:11:55 +0800 Subject: [PATCH] [INLONG-11491][SDK] Fix the judgment error of onMessageAck function in MetricSendCallBack class (#11492) --- .../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 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);