Skip to content

Commit 6972e23

Browse files
authored
Merge pull request #2260 from yue9944882/flake/rate-limit-queue-backoff
Flake: Fixes rate-limit queue flakiness
2 parents 387333a + 0d94399 commit 6972e23

File tree

1 file changed

+4
-3
lines changed

1 file changed

+4
-3
lines changed

extended/src/test/java/io/kubernetes/client/extended/workqueue/DefaultRateLimitQueueTest.java

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,6 @@
1717
import io.kubernetes.client.extended.workqueue.ratelimiter.RateLimiter;
1818
import java.time.Duration;
1919
import java.util.concurrent.Executors;
20-
import java.util.concurrent.TimeUnit;
2120
import org.junit.Test;
2221

2322
public class DefaultRateLimitQueueTest {
@@ -26,9 +25,11 @@ private static class MockRateLimiter<T> implements RateLimiter<T> {
2625

2726
private int count;
2827

28+
private static Duration mockConstantBackoff = Duration.ofMillis(500);
29+
2930
@Override
3031
public Duration when(Object item) {
31-
return Duration.ofMillis(500);
32+
return mockConstantBackoff;
3233
}
3334

3435
@Override
@@ -53,6 +54,6 @@ public void testSimpleRateLimitQueue() throws Exception {
5354
rlq.addRateLimited("foo");
5455
rlq.get();
5556
long t2 = System.nanoTime();
56-
assertTrue(t2 - t1 > TimeUnit.MILLISECONDS.toNanos(500));
57+
assertTrue(t2 - t1 > MockRateLimiter.mockConstantBackoff.toNanos());
5758
}
5859
}

0 commit comments

Comments
 (0)