diff --git a/server/src/main/java/io/druid/client/cache/BytesBoundedLinkedQueue.java b/server/src/main/java/io/druid/client/cache/BytesBoundedLinkedQueue.java index 50ca475c0d5..f0ab9763f6b 100644 --- a/server/src/main/java/io/druid/client/cache/BytesBoundedLinkedQueue.java +++ b/server/src/main/java/io/druid/client/cache/BytesBoundedLinkedQueue.java @@ -129,7 +129,7 @@ public abstract class BytesBoundedLinkedQueue extends AbstractQueue implem try { while (currentSize.get() >= capacity) { if (nanos <= 0) { - break; + return false; } nanos = notFull.awaitNanos(nanos); }