HBASE-17601 close() in TableRecordReaderImpl assumes the split has started (Michael Axiak)
This commit is contained in:
parent
5093a49e0b
commit
19e1450b0f
|
@ -154,7 +154,9 @@ public class TableRecordReaderImpl {
|
||||||
}
|
}
|
||||||
|
|
||||||
public void close() {
|
public void close() {
|
||||||
this.scanner.close();
|
if (this.scanner != null) {
|
||||||
|
this.scanner.close();
|
||||||
|
}
|
||||||
try {
|
try {
|
||||||
this.htable.close();
|
this.htable.close();
|
||||||
} catch (IOException ioe) {
|
} catch (IOException ioe) {
|
||||||
|
|
|
@ -161,7 +161,9 @@ public class TableRecordReaderImpl {
|
||||||
*
|
*
|
||||||
*/
|
*/
|
||||||
public void close() {
|
public void close() {
|
||||||
this.scanner.close();
|
if (this.scanner != null) {
|
||||||
|
this.scanner.close();
|
||||||
|
}
|
||||||
try {
|
try {
|
||||||
this.htable.close();
|
this.htable.close();
|
||||||
} catch (IOException ioe) {
|
} catch (IOException ioe) {
|
||||||
|
|
Loading…
Reference in New Issue