|
@@ -20,7 +20,6 @@ package org.apache.hadoop.yarn.server.resourcemanager;
|
|
|
|
|
|
|
|
|
import java.io.IOException;
|
|
|
-import java.net.InetAddress;
|
|
|
import java.util.concurrent.BlockingQueue;
|
|
|
import java.util.concurrent.LinkedBlockingQueue;
|
|
|
|
|
@@ -48,8 +47,8 @@ import org.apache.hadoop.yarn.server.resourcemanager.amlauncher.AMLauncherEventT
|
|
|
import org.apache.hadoop.yarn.server.resourcemanager.amlauncher.ApplicationMasterLauncher;
|
|
|
import org.apache.hadoop.yarn.server.resourcemanager.recovery.Recoverable;
|
|
|
import org.apache.hadoop.yarn.server.resourcemanager.recovery.Store;
|
|
|
-import org.apache.hadoop.yarn.server.resourcemanager.recovery.Store.RMState;
|
|
|
import org.apache.hadoop.yarn.server.resourcemanager.recovery.StoreFactory;
|
|
|
+import org.apache.hadoop.yarn.server.resourcemanager.recovery.Store.RMState;
|
|
|
import org.apache.hadoop.yarn.server.resourcemanager.rmapp.RMApp;
|
|
|
import org.apache.hadoop.yarn.server.resourcemanager.rmapp.RMAppEvent;
|
|
|
import org.apache.hadoop.yarn.server.resourcemanager.rmapp.RMAppEventType;
|
|
@@ -327,7 +326,8 @@ public class ResourceManager extends CompositeService implements Recoverable {
|
|
|
} catch (Throwable t) {
|
|
|
LOG.fatal("Error in handling event type " + event.getType()
|
|
|
+ " to the scheduler", t);
|
|
|
- if (shouldExitOnError) {
|
|
|
+ if (shouldExitOnError
|
|
|
+ && !ShutdownHookManager.get().isShutdownInProgress()) {
|
|
|
LOG.info("Exiting, bbye..");
|
|
|
System.exit(-1);
|
|
|
}
|