diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MultiVersionConsistencyControl.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MultiVersionConsistencyControl.java index 8b9f41b..17e2788 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MultiVersionConsistencyControl.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MultiVersionConsistencyControl.java @@ -36,7 +36,6 @@ public class MultiVersionConsistencyControl { static final long NO_WRITE_NUMBER = 0; private volatile long memstoreRead = 0; - private final Object readWaiters = new Object(); // This is the pending queue of writes. private final LinkedHashSet writeQueue = @@ -178,12 +177,6 @@ boolean advanceMemstore(WriteEntry e) { writeQueue.notifyAll(); } - if (nextReadValue > 0) { - synchronized (readWaiters) { - readWaiters.notifyAll(); - } - } - if (memstoreRead >= e.getWriteNumber()) { return true; }