HBASE-28238 rpcservice should perform some important admin operation to priority ADMIN_QOS (#5558)
HBASE-28238 rpcservice should perform some important admin operation to priority ADMIN_QOS (#5558)
Co-authored-by: selina.yan <selina.yan@huolala.cn>
diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/HBaseRpcServicesBase.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/HBaseRpcServicesBase.java
index 291b38a..b2a0e78 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/HBaseRpcServicesBase.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/HBaseRpcServicesBase.java
@@ -310,6 +310,7 @@
}
@Override
+ @QosPriority(priority = HConstants.ADMIN_QOS)
public UpdateConfigurationResponse updateConfiguration(RpcController controller,
UpdateConfigurationRequest request) throws ServiceException {
try {
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 0538b97..4926aa3 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
@@ -1554,6 +1554,7 @@
}
@Override
+ @QosPriority(priority = HConstants.ADMIN_QOS)
public CompactionSwitchResponse compactionSwitch(RpcController controller,
CompactionSwitchRequest request) throws ServiceException {
rpcPreCheck("compactionSwitch");
@@ -2232,6 +2233,7 @@
* @param request the request
*/
@Override
+ @QosPriority(priority = HConstants.ADMIN_QOS)
public RollWALWriterResponse rollWALWriter(final RpcController controller,
final RollWALWriterRequest request) throws ServiceException {
try {
diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestRSQosFunction.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestRSQosFunction.java
index c6bd896..15ee323 100644
--- a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestRSQosFunction.java
+++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestRSQosFunction.java
@@ -72,5 +72,8 @@
checkMethod(conf, "CloseRegion", HConstants.ADMIN_QOS, qosFunction);
checkMethod(conf, "CompactRegion", HConstants.ADMIN_QOS, qosFunction);
checkMethod(conf, "FlushRegion", HConstants.ADMIN_QOS, qosFunction);
+ checkMethod(conf, "UpdateConfiguration", HConstants.ADMIN_QOS, qosFunction);
+ checkMethod(conf, "CompactionSwitch", HConstants.ADMIN_QOS, qosFunction);
+ checkMethod(conf, "RollWALWriter", HConstants.ADMIN_QOS, qosFunction);
}
}
