From 413a1f34b1c7fc901273c214c509c1b24152b71e Mon Sep 17 00:00:00 2001
From: shenjianeng <sjn@dxy.cn>
Date: Wed, 22 Nov 2023 16:47:33 +0800
Subject: [PATCH] fix sleepMs overflow

---
 .../java/org/apache/curator/retry/ExponentialBackoffRetry.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/curator-client/src/main/java/org/apache/curator/retry/ExponentialBackoffRetry.java b/curator-client/src/main/java/org/apache/curator/retry/ExponentialBackoffRetry.java
index 929b3b372..44aac9bde 100644
--- a/curator-client/src/main/java/org/apache/curator/retry/ExponentialBackoffRetry.java
+++ b/curator-client/src/main/java/org/apache/curator/retry/ExponentialBackoffRetry.java
@@ -64,7 +64,7 @@ public int getBaseSleepTimeMs() {
     @Override
     protected long getSleepTimeMs(int retryCount, long elapsedTimeMs) {
         // copied from Hadoop's RetryPolicies.java
-        long sleepMs = baseSleepTimeMs * Math.max(1, random.nextInt(1 << (retryCount + 1)));
+        long sleepMs = (long) baseSleepTimeMs * Math.max(1, random.nextInt(1 << (retryCount + 1)));
         if (sleepMs > maxSleepMs) {
             log.warn(String.format("Sleep extension too large (%d). Pinning to %d", sleepMs, maxSleepMs));
             sleepMs = maxSleepMs;