HBASE-20350 NullPointerException in Scanner during close()
This commit is contained in:
parent
199b392ec8
commit
281c29ff60
|
@ -224,8 +224,8 @@ public class KeyValueHeap extends NonReversedNonLazyKeyValueScanner
|
||||||
this.current.close();
|
this.current.close();
|
||||||
}
|
}
|
||||||
if (this.heap != null) {
|
if (this.heap != null) {
|
||||||
KeyValueScanner scanner;
|
// Order of closing the scanners shouldn't matter here, so simply iterate and close them.
|
||||||
while ((scanner = this.heap.poll()) != null) {
|
for (KeyValueScanner scanner : heap) {
|
||||||
scanner.close();
|
scanner.close();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue