This is an automated email from the ASF dual-hosted git repository. zhangduo pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/hbase.git
commit dca0b593cf3e325db2b8f8e1b21014583b7eb4d3 Author: 王伟 <[email protected]> AuthorDate: Wed Sep 23 14:36:00 2020 +0800 HBASE-25073 Should not use XXXService.Interface.class.getSimpleName as stub key prefix in AsyncConnectionImpl (#2443) Signed-off-by: Duo Zhang <[email protected]> --- .../main/java/org/apache/hadoop/hbase/client/AsyncConnectionImpl.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncConnectionImpl.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncConnectionImpl.java index 97b70e1..406af0d 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncConnectionImpl.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncConnectionImpl.java @@ -254,7 +254,7 @@ class AsyncConnectionImpl implements AsyncConnection { ClientService.Interface getRegionServerStub(ServerName serverName) throws IOException { return ConcurrentMapUtils.computeIfAbsentEx(rsStubs, - getStubKey(ClientService.Interface.class.getSimpleName(), serverName, hostnameCanChange), + getStubKey(ClientService.getDescriptor().getName(), serverName, hostnameCanChange), () -> createRegionServerStub(serverName)); } @@ -268,7 +268,7 @@ class AsyncConnectionImpl implements AsyncConnection { AdminService.Interface getAdminStub(ServerName serverName) throws IOException { return ConcurrentMapUtils.computeIfAbsentEx(adminSubs, - getStubKey(AdminService.Interface.class.getSimpleName(), serverName, hostnameCanChange), + getStubKey(AdminService.getDescriptor().getName(), serverName, hostnameCanChange), () -> createAdminServerStub(serverName)); }
