[INLONG-11493][SDK] Inlong SDK Dirty Sink supports retry sending

apache · Nov 13, 2024 · 869cdd4 · 869cdd4
1 parent c8bbe4b
commit 869cdd4
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/...dk/dirty-data-sdk/src/main/java/org/apache/inlong/sdk/dirtydata/InlongSdkDirtySender.java b/...dk/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();