This is an automated email from the ASF dual-hosted git repository.
sunilg 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 7861a5e YARN-9033. ResourceHandlerChain#bootstrap is invoked twice
during NM start if LinuxContainerExecutor enabled. Contributed by Zhankun Tang.
7861a5e is described below
commit 7861a5eb1afd3b8c485b1db83f3bb21a50928e4e
Author: Sunil G <[email protected]>
AuthorDate: Fri May 31 10:22:26 2019 +0530
YARN-9033. ResourceHandlerChain#bootstrap is invoked twice during NM start
if LinuxContainerExecutor enabled. Contributed by Zhankun Tang.
---
.../scheduler/ContainerScheduler.java | 25 +++++++---------------
1 file changed, 8 insertions(+), 17 deletions(-)
diff --git
a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/containermanager/scheduler/ContainerScheduler.java
b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/containermanager/scheduler/ContainerScheduler.java
index cfbde87..854ad53 100644
---
a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/containermanager/scheduler/ContainerScheduler.java
+++
b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/containermanager/scheduler/ContainerScheduler.java
@@ -35,7 +35,6 @@ import
org.apache.hadoop.yarn.server.nodemanager.containermanager.container.Cont
import
org.apache.hadoop.yarn.server.nodemanager.containermanager.container.ContainerImpl;
import
org.apache.hadoop.yarn.server.nodemanager.containermanager.linux.resources.ResourceHandlerChain;
-import
org.apache.hadoop.yarn.server.nodemanager.containermanager.linux.resources.ResourceHandlerException;
import
org.apache.hadoop.yarn.server.nodemanager.containermanager.linux.resources.ResourceHandlerModule;
import org.apache.hadoop.yarn.server.nodemanager.containermanager.monitor
.ChangeMonitoringContainerResourceEvent;
@@ -44,7 +43,6 @@ import
org.apache.hadoop.yarn.server.nodemanager.containermanager.monitor.Contai
import org.apache.hadoop.yarn.server.nodemanager.metrics.NodeManagerMetrics;
-import org.apache.hadoop.yarn.server.nodemanager.recovery.NMStateStoreService;
import org.apache.hadoop.yarn.server.nodemanager.recovery.NMStateStoreService
.RecoveredContainerState;
import
org.apache.hadoop.yarn.server.nodemanager.recovery.NMStateStoreService.RecoveredContainerStatus;
@@ -132,21 +130,14 @@ public class ContainerScheduler extends AbstractService
implements
@Override
public void serviceInit(Configuration conf) throws Exception {
super.serviceInit(conf);
- try {
- if (resourceHandlerChain == null) {
- resourceHandlerChain = ResourceHandlerModule
- .getConfiguredResourceHandlerChain(conf, context);
- }
- LOG.debug("Resource handler chain enabled = {}",
- (resourceHandlerChain != null));
- if (resourceHandlerChain != null) {
- LOG.debug("Bootstrapping resource handler chain");
- resourceHandlerChain.bootstrap(conf);
- }
- } catch (ResourceHandlerException e) {
- LOG.error("Failed to bootstrap configured resource subsystems! ", e);
- throw new IOException(
- "Failed to bootstrap configured resource subsystems!");
+ if (resourceHandlerChain == null) {
+ resourceHandlerChain = ResourceHandlerModule
+ .getConfiguredResourceHandlerChain(conf, context);
+ }
+ if (LOG.isDebugEnabled()) {
+ LOG.debug("Resource handler chain enabled = " + (resourceHandlerChain
+ != null));
+
}
this.usePauseEventForPreemption =
conf.getBoolean(
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
