From 869cdd476b39d1c1391f0a7e8d924a09239018b1 Mon Sep 17 00:00:00 2001
From: vernedeng <vernedeng@apache.org>
Date: Wed, 13 Nov 2024 21:44:13 +0800
Subject: [PATCH] [INLONG-11493][SDK] Inlong SDK Dirty Sink supports retry
 sending

---
 .../org/apache/inlong/sdk/dirtydata/InlongSdkDirtySender.java    | 1 +
 1 file changed, 1 insertion(+)

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 681b9f549c..243b4d12e1 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
@@ -83,6 +83,7 @@ private void doSendDirtyMessage() {
             try {
                 DirtyMessageWrapper messageWrapper = dirtyDataQueue.poll();
                 if (messageWrapper == null) {
+                    Thread.sleep(100L);
                     continue;
                 }
                 messageWrapper.increaseRetry();