From 8b23d2b79dc0ce80ee3612938ac825fbd2922a1b Mon Sep 17 00:00:00 2001
From: vernedeng <vernedeng@apache.org>
Date: Tue, 26 Nov 2024 17:00:51 +0800
Subject: [PATCH] fix

---
 .../apache/inlong/sdk/dirtydata/InlongSdkDirtySender.java | 8 +++++---
 1 file changed, 5 insertions(+), 3 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 14fd9e697e..4565a2947d 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
@@ -77,10 +77,12 @@ public void sendDirtyMessageSync(DirtyMessageWrapper messageWrapper) throws Inte
         dirtyDataQueue.put(messageWrapper);
     }
 
-    public void sendDirtyMessageAsync(DirtyMessageWrapper messageWrapper) throws InterruptedException {
-        if(!dirtyDataQueue.offer(messageWrapper)) {
-            log.warn("the dirty data queue is full, you can increase the size of queue by configure maxCallbackSize");
+    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;
     }
 
     private void doSendDirtyMessage() {