diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/KeyValueHeap.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/KeyValueHeap.java index 7125df3..30dc2c1 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/KeyValueHeap.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/KeyValueHeap.java @@ -326,6 +326,7 @@ public class KeyValueHeap extends NonReversedNonLazyKeyValueScanner LOG.warn("close KeyValueScanner error", ce); } } + throw e; } // Heap is returning empty, scanner is done