Skip to content

Commit 5f36943

Browse files
authored
YARN-11876. Fix AsyncDispatcher crash in TestAppManager. (#8014) Contributed by Shilun Fan
* YARN-11876. Fix AsyncDispatcher crash in TestAppManager. Reviewed-by: Tsz-Wo Nicholas Sze <szetszwo@apache.org> Signed-off-by: Shilun Fan <slfan1989@apache.org>
1 parent d9c3308 commit 5f36943

File tree

1 file changed

+3
-3
lines changed
  • hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager

1 file changed

+3
-3
lines changed

hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/TestAppManager.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -45,7 +45,6 @@
4545
import org.apache.hadoop.yarn.api.records.ResourceRequest;
4646
import org.apache.hadoop.yarn.conf.YarnConfiguration;
4747
import org.apache.hadoop.yarn.event.AsyncDispatcher;
48-
import org.apache.hadoop.yarn.event.Dispatcher;
4948
import org.apache.hadoop.yarn.event.EventHandler;
5049
import org.apache.hadoop.yarn.exceptions.InvalidResourceRequestException;
5150
import org.apache.hadoop.yarn.exceptions.YarnException;
@@ -184,7 +183,8 @@ public RMContext mockRMContext(int n, long time) {
184183
for (RMApp app : apps) {
185184
map.put(app.getApplicationId(), app);
186185
}
187-
Dispatcher rmDispatcher = new AsyncDispatcher();
186+
AsyncDispatcher rmDispatcher = new AsyncDispatcher();
187+
rmDispatcher.disableExitOnDispatchException();
188188
ContainerAllocationExpirer containerAllocationExpirer = new ContainerAllocationExpirer(
189189
rmDispatcher);
190190
AMLivelinessMonitor amLivelinessMonitor = new AMLivelinessMonitor(
@@ -200,7 +200,7 @@ public ConcurrentMap<ApplicationId, RMApp> getRMApps() {
200200
return map;
201201
}
202202
};
203-
((RMContextImpl)context).setStateStore(mock(RMStateStore.class));
203+
((RMContextImpl) context).setStateStore(mock(RMStateStore.class));
204204
metricsPublisher = mock(SystemMetricsPublisher.class);
205205
context.setSystemMetricsPublisher(metricsPublisher);
206206
context.setRMApplicationHistoryWriter(writer);

0 commit comments

Comments
 (0)