diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/RWQueueRpcExecutor.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/RWQueueRpcExecutor.java index ef1aec8437f6..9feef2549f31 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/RWQueueRpcExecutor.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/RWQueueRpcExecutor.java @@ -350,12 +350,7 @@ private boolean isWriteRequest(final RequestHeader header, final Message param) } private boolean isScanRequest(final RequestHeader header, final Message param) { - if (param instanceof ScanRequest) { - // The first scan request will be executed as a "short read" - ScanRequest request = (ScanRequest)param; - return request.hasScannerId(); - } - return false; + return param instanceof ScanRequest; } /* diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/ipc/TestSimpleRpcScheduler.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/ipc/TestSimpleRpcScheduler.java index 347b23189a4b..940f1c227626 100644 --- a/hbase-server/src/test/java/org/apache/hadoop/hbase/ipc/TestSimpleRpcScheduler.java +++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/ipc/TestSimpleRpcScheduler.java @@ -291,7 +291,7 @@ public void testScanQueues() throws Exception { CallRunner scanCallTask = mock(CallRunner.class); RpcServer.Call scanCall = mock(RpcServer.Call.class); - scanCall.param = ScanRequest.newBuilder().setScannerId(1).build(); + scanCall.param = ScanRequest.newBuilder().build(); RequestHeader scanHead = RequestHeader.newBuilder().setMethodName("scan").build(); when(scanCallTask.getCall()).thenReturn(scanCall); when(scanCall.getHeader()).thenReturn(scanHead);