commit 111f3a6bdcd562db0493e52243e5cec933cc36ef
author shenjianeng <30279020+shenjianeng@users.noreply.github.com> Wed Dec 20 12:44:37 2023 +0800
committer GitHub <noreply@github.com> Wed Dec 20 12:44:37 2023 +0800
tree 2f60509134c92dbd0e09adcee89ced875b9fad2b
parent e949731759f18f7d747651f6228ed24110367369

CURATOR-262. Fix sleepMs overflow (#490)

Co-authored-by: shenjianeng <sjn@dxy.cn>

curator-client/src/main/java/org/apache/curator/retry/ExponentialBackoffRetry.java

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 929b3b3..44aac9b 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 @@
     @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;