diff --git hbase-server/src/main/java/org/apache/hadoop/hbase/util/BoundedPriorityBlockingQueue.java hbase-server/src/main/java/org/apache/hadoop/hbase/util/BoundedPriorityBlockingQueue.java index b525136..09531d1 100644 --- hbase-server/src/main/java/org/apache/hadoop/hbase/util/BoundedPriorityBlockingQueue.java +++ hbase-server/src/main/java/org/apache/hadoop/hbase/util/BoundedPriorityBlockingQueue.java @@ -245,7 +245,7 @@ public class BoundedPriorityBlockingQueue extends AbstractQueue implements E result = null; try { while (queue.size() == 0 && nanos > 0) { - notEmpty.awaitNanos(nanos); + nanos = notEmpty.awaitNanos(nanos); } if (queue.size() > 0) { result = queue.poll();