This is an automated email from the ASF dual-hosted git repository. zhangduo pushed a commit to branch branch-3 in repository https://gitbox.apache.org/repos/asf/hbase.git
commit ea245c5c7218d154632e9bd88aa39f251af3a4bf Author: Liu Xiao <[email protected]> AuthorDate: Wed Feb 25 21:04:31 2026 +0800 HBASE-29919 Test case TestSecureIPC#testRpcServerDisallowFallbackToSimpleAuth failed (#7794) Signed-off-by: Duo Zhang <[email protected]> (cherry picked from commit 80303ee66b6b2dba19f74a9c4da000314f5407b6) --- .../org/apache/hadoop/hbase/security/AbstractTestSecureIPC.java | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/security/AbstractTestSecureIPC.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/security/AbstractTestSecureIPC.java index ad61b8131fe..a783f53cec0 100644 --- a/hbase-server/src/test/java/org/apache/hadoop/hbase/security/AbstractTestSecureIPC.java +++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/security/AbstractTestSecureIPC.java @@ -39,6 +39,7 @@ import java.io.IOException; import java.lang.reflect.Field; import java.net.InetAddress; import java.net.InetSocketAddress; +import java.net.SocketException; import java.security.PrivilegedExceptionAction; import java.util.ArrayList; import java.util.Collections; @@ -196,10 +197,11 @@ public class AbstractTestSecureIPC { serverConf.setBoolean(RpcServer.FALLBACK_TO_INSECURE_CLIENT_AUTH, false); IOException error = assertThrows(IOException.class, () -> callRpcService(User.create(clientUgi))); - // server just closes the connection, so we could get broken pipe, or EOF, or connection closed + // server just closes the connection, so we could get broken pipe, or EOF, or connection closed, + // or socket exception if (error.getMessage() == null || !error.getMessage().contains("Broken pipe")) { - assertThat(error, - either(instanceOf(EOFException.class)).or(instanceOf(ConnectionClosedException.class))); + assertThat(error, either(instanceOf(EOFException.class)) + .or(instanceOf(ConnectionClosedException.class)).or(instanceOf(SocketException.class))); } }
