diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/RSRpcServices.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/RSRpcServices.java index 79d77c7f2967..5640962e4751 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/RSRpcServices.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/RSRpcServices.java @@ -1711,22 +1711,18 @@ public CompactRegionResponse compactRegion(final RpcController controller, @Override public CompactionSwitchResponse compactionSwitch(RpcController controller, CompactionSwitchRequest request) throws ServiceException { + rpcPreCheck("compactionSwitch"); final CompactSplit compactSplitThread = regionServer.getCompactSplitThread(); - try { - checkOpen(); - requestCount.increment(); - boolean prevState = compactSplitThread.isCompactionsEnabled(); - CompactionSwitchResponse response = - CompactionSwitchResponse.newBuilder().setPrevState(prevState).build(); - if (prevState == request.getEnabled()) { - // passed in requested state is same as current state. No action required - return response; - } - compactSplitThread.switchCompaction(request.getEnabled()); + requestCount.increment(); + boolean prevState = compactSplitThread.isCompactionsEnabled(); + CompactionSwitchResponse response = + CompactionSwitchResponse.newBuilder().setPrevState(prevState).build(); + if (prevState == request.getEnabled()) { + // passed in requested state is same as current state. No action required return response; - } catch (IOException ie) { - throw new ServiceException(ie); } + compactSplitThread.switchCompaction(request.getEnabled()); + return response; } /**