From 41b6563b7cccb05a61599c751303ec10cab23a79 Mon Sep 17 00:00:00 2001 From: Prabhu Joseph Date: Mon, 18 Feb 2019 17:24:16 +0530 Subject: [PATCH] YARN-9311 --- .../apache/hadoop/yarn/server/resourcemanager/TestRMRestart.java | 9 ++++++++- 1 file changed, 8 insertions(+), 1 deletion(-) diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/TestRMRestart.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/TestRMRestart.java index be72756..b946663 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/TestRMRestart.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/TestRMRestart.java @@ -1657,7 +1657,13 @@ protected void handleStoreEvent(RMStateStoreEvent event) { // start RM final MockRM rm1 = createMockRM(conf, memStore); rm1.disableDrainEventsImplicitly(); - rm1.start(); + + Thread t = new Thread() { + public void run() { + rm1.start(); + } + }; + t.start(); // create apps. final ArrayList appList = new ArrayList(); @@ -1679,6 +1685,7 @@ protected void handleStoreEvent(RMStateStoreEvent event) { Assert.assertTrue(rmAppState.size() == 0); // stop rm + memStore.close(); rm1.stop(); // Assert app info is still saved even if stop is called with pending saving -- 2.7.4 (Apple Git-66)