You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by rh...@apache.org on 2022/03/09 22:22:22 UTC
[kafka] 03/03: KAFKA-12879: Remove extra sleep (#11872)
This is an automated email from the ASF dual-hosted git repository.
rhauch pushed a commit to branch 3.1
in repository https://gitbox.apache.org/repos/asf/kafka.git
commit c4f84c842961f076ec7962a3f89b50a8ee8cbf61
Author: Randall Hauch <rh...@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);