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);