You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by zh...@apache.org on 2021/10/26 07:50:57 UTC
[hbase] branch branch-2 updated: HBASE-26394 Cache in
RSRpcServices.executeProcedures does not take effect (#3794)
This is an automated email from the ASF dual-hosted git repository.
zhangduo pushed a commit to branch branch-2
in repository https://gitbox.apache.org/repos/asf/hbase.git
The following commit(s) were added to refs/heads/branch-2 by this push:
new b417757 HBASE-26394 Cache in RSRpcServices.executeProcedures does not take effect (#3794)
b417757 is described below
commit b4177577ac1bd502c5ec04de39e682d6669251d8
Author: chenglei <ch...@apache.org>
AuthorDate: Tue Oct 26 14:44:33 2021 +0800
HBASE-26394 Cache in RSRpcServices.executeProcedures does not take effect (#3794)
Signed-off-by: Xiaolin Ha <ha...@apache.org>
Signed-off-by: Duo Zhang <zh...@apache.org>
---
.../java/org/apache/hadoop/hbase/regionserver/RSRpcServices.java | 6 +++++-
1 file changed, 5 insertions(+), 1 deletion(-)
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 626e1d0..3ef64ec 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
@@ -3848,7 +3848,8 @@ public class RSRpcServices implements HBaseRPCErrorHandler, AdminService.Blockin
long masterSystemTime = request.hasMasterSystemTime() ? request.getMasterSystemTime() : -1;
for (RegionOpenInfo regionOpenInfo : request.getOpenInfoList()) {
RegionInfo regionInfo = ProtobufUtil.toRegionInfo(regionOpenInfo.getRegion());
- TableDescriptor tableDesc = tdCache.get(regionInfo.getTable());
+ TableName tableName = regionInfo.getTable();
+ TableDescriptor tableDesc = tdCache.get(tableName);
if (tableDesc == null) {
try {
tableDesc = regionServer.getTableDescriptors().get(regionInfo.getTable());
@@ -3860,6 +3861,9 @@ public class RSRpcServices implements HBaseRPCErrorHandler, AdminService.Blockin
LOG.warn("Failed to get TableDescriptor of {}, will try again in the handler",
regionInfo.getTable(), e);
}
+ if(tableDesc != null) {
+ tdCache.put(tableName, tableDesc);
+ }
}
if (regionOpenInfo.getFavoredNodesCount() > 0) {
regionServer.updateRegionFavoredNodesMapping(regionInfo.getEncodedName(),