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

HBASE-27185 Addendum fix TestShadeSaslAuthenticationProvider

Browse Source
This commit is contained in:
Duo Zhang 2022-07-28 17:20:13 +08:00
parent 7910f7738f
commit 5e4ddad9a9
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcConnection.java
View File

@ -218,8 +218,9 @@ class NettyRpcConnection extends RpcConnection {
failInit(ch, e);
return;
}
ch.pipeline().addFirst(new SaslChallengeDecoder(), saslHandler);
NettyFutureUtils.consume(saslPromise.addListener(new FutureListener<Boolean>() {
ch.pipeline().addFirst("SaslDecoder", new SaslChallengeDecoder()).addAfter("SaslDecoder",
"SaslHandler", saslHandler);
NettyFutureUtils.addListener(saslPromise, new FutureListener<Boolean>() {
@Override
public void operationComplete(Future<Boolean> future) throws Exception {
@ -266,7 +267,7 @@ class NettyRpcConnection extends RpcConnection {
failInit(ch, toIOE(error));
}
}
}));
});
}
private void connect() throws UnknownHostException {