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() {