(hbase) branch branch-3 updated: HBASE-29700 Always close RPC servers in AbstractTestIPC (#7434)

[stoty]

This is an automated email from the ASF dual-hosted git repository.

stoty pushed a commit to branch branch-3
in repository https://gitbox.apache.org/repos/asf/hbase.git


The following commit(s) were added to refs/heads/branch-3 by this push:
     new 820514b942c HBASE-29700 Always close RPC servers in AbstractTestIPC 
(#7434)
820514b942c is described below

commit 820514b942c677c72bf804309a4a2119a4b3c140
Author: Istvan Toth <st...@apache.org>
AuthorDate: Tue Nov 4 18:35:38 2025 +0100

    HBASE-29700 Always close RPC servers in AbstractTestIPC (#7434)
    
    Signed-off-by: Duo Zhang <zhang...@apache.org>
    (cherry picked from commit e2e2676a10468d1716ffd297ab664669d25da01b)
---
 .../test/java/org/apache/hadoop/hbase/ipc/AbstractTestIPC.java    | 8 ++++++++
 1 file changed, 8 insertions(+)

diff --git 
a/hbase-server/src/test/java/org/apache/hadoop/hbase/ipc/AbstractTestIPC.java 
b/hbase-server/src/test/java/org/apache/hadoop/hbase/ipc/AbstractTestIPC.java
index 248e8f9d8ce..0a13debf978 100644
--- 
a/hbase-server/src/test/java/org/apache/hadoop/hbase/ipc/AbstractTestIPC.java
+++ 
b/hbase-server/src/test/java/org/apache/hadoop/hbase/ipc/AbstractTestIPC.java
@@ -581,6 +581,8 @@ public abstract class AbstractTestIPC {
         everyItem(allOf(hasStatusWithCode(StatusCode.OK),
           hasTraceId(traceRule.getSpans().iterator().next().getTraceId()),
           hasDuration(greaterThanOrEqualTo(Duration.ofMillis(100L))))));
+    } finally {
+      rpcServer.stop();
     }
   }
 
@@ -609,6 +611,8 @@ public abstract class AbstractTestIPC {
       assertFalse("no spans provided", traceRule.getSpans().isEmpty());
       assertThat(traceRule.getSpans(), 
everyItem(allOf(hasStatusWithCode(StatusCode.ERROR),
         hasTraceId(traceRule.getSpans().iterator().next().getTraceId()))));
+    } finally {
+      rpcServer.stop();
     }
   }
 
@@ -670,6 +674,8 @@ public abstract class AbstractTestIPC {
       GetConnectionRegistryResponse resp =
         stub.getConnectionRegistry(null, 
GetConnectionRegistryRequest.getDefaultInstance());
       assertEquals(clusterId, resp.getClusterId());
+    } finally {
+      rpcServer.stop();
     }
   }
 
@@ -701,6 +707,8 @@ public abstract class AbstractTestIPC {
       assertEquals(FatalConnectionException.class.getName(),
         ((RemoteException) pcrc.getFailed()).getClassName());
       assertThat(pcrc.getFailed().getMessage(), startsWith("Expected 
HEADER="));
+    } finally {
+      rpcServer.stop();
     }
   }
 }