mirror of https://github.com/apache/druid.git
minor fix
This commit is contained in:
parent
61d99bb8f2
commit
db93e45bef
|
@ -129,7 +129,7 @@ public abstract class BytesBoundedLinkedQueue<E> extends AbstractQueue<E> implem
|
||||||
try {
|
try {
|
||||||
while (currentSize.get() >= capacity) {
|
while (currentSize.get() >= capacity) {
|
||||||
if (nanos <= 0) {
|
if (nanos <= 0) {
|
||||||
break;
|
return false;
|
||||||
}
|
}
|
||||||
nanos = notFull.awaitNanos(nanos);
|
nanos = notFull.awaitNanos(nanos);
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue