This is an automated email from the ASF dual-hosted git repository.
cnauroth pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/hadoop.git
The following commit(s) were added to refs/heads/trunk by this push:
new 0e031c0f528 YARN-11935. Fix deadlock in
TestRMHA#testTransitionedToStandbyShouldNotHang.
0e031c0f528 is described below
commit 0e031c0f528e1f00a3cfad32b427ce6faf12a82d
Author: slfan1989 <[email protected]>
AuthorDate: Mon Feb 23 17:23:19 2026 +0000
YARN-11935. Fix deadlock in TestRMHA#testTransitionedToStandbyShouldNotHang.
Closes #8267
Signed-off-by: Chris Nauroth <[email protected]>
---
.../apache/hadoop/yarn/server/resourcemanager/TestRMHA.java | 11 +++++++++++
1 file changed, 11 insertions(+)
diff --git
a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/TestRMHA.java
b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/TestRMHA.java
index 9503a435a4b..e6b2a5668ac 100644
---
a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/TestRMHA.java
+++
b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/TestRMHA.java
@@ -67,6 +67,7 @@
import org.apache.hadoop.yarn.event.DrainDispatcher;
import org.apache.hadoop.yarn.event.Event;
import org.apache.hadoop.yarn.event.EventHandler;
+import org.apache.hadoop.yarn.event.InlineDispatcher;
import org.apache.hadoop.yarn.exceptions.YarnRuntimeException;
import
org.apache.hadoop.yarn.server.resourcemanager.recovery.records.ApplicationStateData;
import
org.apache.hadoop.yarn.server.resourcemanager.recovery.MemoryRMStateStore;
@@ -490,6 +491,16 @@ public void updateApplicationState(ApplicationStateData
appState) {
};
memStore.init(conf);
rm = new MockRM(conf, memStore) {
+ @Override
+ protected Dispatcher createDispatcher() {
+ return new InlineDispatcher();
+ }
+
+ @Override
+ public void drainEvents() {
+ // InlineDispatcher dispatches synchronously; nothing to drain here.
+ }
+
@Override
void stopActiveServices() {
try {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
