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);