Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-26008 Fix typo in AsyncConnectionImpl (#3391) 

Signed-off-by: Duo Zhang <zhangduo@apache.org>
This commit is contained in:
niuyulin 2021-06-16 19:00:03 +08:00 committed by GitHub
parent 555f8b461f
commit 7466e08aec
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncConnectionImpl.java
View File

@ -103,7 +103,8 @@ class AsyncConnectionImpl implements AsyncConnection {
private final NonceGenerator nonceGenerator; private final NonceGenerator nonceGenerator;
private final ConcurrentMap<String, ClientService.Interface> rsStubs = new ConcurrentHashMap<>(); private final ConcurrentMap<String, ClientService.Interface> rsStubs = new ConcurrentHashMap<>();
private final ConcurrentMap<String, AdminService.Interface> adminSubs = new ConcurrentHashMap<>(); private final ConcurrentMap<String, AdminService.Interface> adminStubs =
new ConcurrentHashMap<>();
private final AtomicReference<MasterService.Interface> masterStub = new AtomicReference<>(); private final AtomicReference<MasterService.Interface> masterStub = new AtomicReference<>();
@ -283,7 +284,7 @@ class AsyncConnectionImpl implements AsyncConnection {
} }
AdminService.Interface getAdminStub(ServerName serverName) throws IOException { AdminService.Interface getAdminStub(ServerName serverName) throws IOException {
return ConcurrentMapUtils.computeIfAbsentEx(adminSubs, return ConcurrentMapUtils.computeIfAbsentEx(adminStubs,
getStubKey(AdminService.getDescriptor().getName(), serverName), getStubKey(AdminService.getDescriptor().getName(), serverName),
() -> createAdminServerStub(serverName)); () -> createAdminServerStub(serverName));
} }