diff --git a/extended/src/test/java/io/kubernetes/client/extended/workqueue/DefaultDelayingQueueTest.java b/extended/src/test/java/io/kubernetes/client/extended/workqueue/DefaultDelayingQueueTest.java index f29791b688..5d4d9841a7 100644 --- a/extended/src/test/java/io/kubernetes/client/extended/workqueue/DefaultDelayingQueueTest.java +++ b/extended/src/test/java/io/kubernetes/client/extended/workqueue/DefaultDelayingQueueTest.java @@ -45,7 +45,9 @@ void simpleDelayingQueue() throws Exception { String item = queue.get(); queue.done(item); - Thread.sleep(10 * 1000L); + // The only entry was released above, so once nothing is left waiting to be added the queue + // cannot receive anything else. Poll for that instead of sleeping for a fixed 10 seconds. + assertThat(waitForWaitingQueueToFill(queue)).isTrue(); assertThat(0).isEqualTo(queue.length()); }