From a60ce3d9c2a0443b6c2b650829915698290b87e5 Mon Sep 17 00:00:00 2001 From: vernedeng Date: Tue, 26 Nov 2024 17:20:01 +0800 Subject: [PATCH] remove logs --- .../apache/inlong/sdk/dirtydata/InlongSdkDirtySender.java | 6 +----- 1 file changed, 1 insertion(+), 5 deletions(-) diff --git a/inlong-sdk/dirty-data-sdk/src/main/java/org/apache/inlong/sdk/dirtydata/InlongSdkDirtySender.java b/inlong-sdk/dirty-data-sdk/src/main/java/org/apache/inlong/sdk/dirtydata/InlongSdkDirtySender.java index 9130da7484..74cfcffa21 100644 --- a/inlong-sdk/dirty-data-sdk/src/main/java/org/apache/inlong/sdk/dirtydata/InlongSdkDirtySender.java +++ b/inlong-sdk/dirty-data-sdk/src/main/java/org/apache/inlong/sdk/dirtydata/InlongSdkDirtySender.java @@ -78,11 +78,7 @@ public void sendDirtyMessage(DirtyMessageWrapper messageWrapper) throws Interrup } public boolean sendDirtyMessageAsync(DirtyMessageWrapper messageWrapper) { - boolean result = dirtyDataQueue.offer(messageWrapper); - if (!result) { - log.warn("send dirty message async queue is full, you can increase maxCallbackSize"); - } - return result; + return dirtyDataQueue.offer(messageWrapper); } private void doSendDirtyMessage() {