This is an automated email from the ASF dual-hosted git repository.

rhauch pushed a commit to branch 3.0
in repository https://gitbox.apache.org/repos/asf/kafka.git

commit 5265e1a607899bb562194eb1b0b6ff0b375d1626
Author: Randall Hauch <rha...@gmail.com>
AuthorDate: Wed Mar 9 15:11:46 2022 -0600

    KAFKA-12879: Remove extra sleep (#11872)
---
 .../runtime/src/main/java/org/apache/kafka/connect/util/RetryUtil.java   | 1 -
 1 file changed, 1 deletion(-)

diff --git 
a/connect/runtime/src/main/java/org/apache/kafka/connect/util/RetryUtil.java 
b/connect/runtime/src/main/java/org/apache/kafka/connect/util/RetryUtil.java
index 64fd97c..84b9af1 100644
--- a/connect/runtime/src/main/java/org/apache/kafka/connect/util/RetryUtil.java
+++ b/connect/runtime/src/main/java/org/apache/kafka/connect/util/RetryUtil.java
@@ -96,7 +96,6 @@ public class RetryUtil {
                 }
                 Utils.sleep(retryBackoffMs);
             }
-            Utils.sleep(retryBackoffMs);
         } while (System.currentTimeMillis() < end);
 
         throw new ConnectException("Fail to " + descriptionStr + " after " + 
attempt + " attempts.  Reason: " + lastError.getMessage(), lastError);

Reply via email to