diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/thrift2/ThriftHBaseServiceHandler.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/thrift2/ThriftHBaseServiceHandler.java index 930107556dc..1aa150aa8c4 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/thrift2/ThriftHBaseServiceHandler.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/thrift2/ThriftHBaseServiceHandler.java @@ -336,11 +336,17 @@ public class ThriftHBaseServiceHandler implements THBaseService.Iface { @Override public void closeScanner(int scannerId) throws TIOError, TIllegalArgument, TException { - if (removeScanner(scannerId) == null) { + LOG.debug("scannerClose: id=" + scannerId); + ResultScanner scanner = getScanner(scannerId); + if (scanner == null) { + String message = "scanner ID is invalid"; + LOG.warn(message); TIllegalArgument ex = new TIllegalArgument(); ex.setMessage("Invalid scanner Id"); throw ex; } + scanner.close(); + removeScanner(scannerId); } }