|
@@ -26,11 +26,14 @@ import java.util.concurrent.ConcurrentHashMap;
|
|
|
import java.util.concurrent.ConcurrentMap;
|
|
|
import java.util.concurrent.ConcurrentSkipListMap;
|
|
|
|
|
|
+import org.apache.commons.logging.Log;
|
|
|
+import org.apache.commons.logging.LogFactory;
|
|
|
import org.apache.hadoop.NodeHealthCheckerService;
|
|
|
import org.apache.hadoop.conf.Configuration;
|
|
|
import org.apache.hadoop.metrics2.lib.DefaultMetricsSystem;
|
|
|
import org.apache.hadoop.security.SecurityUtil;
|
|
|
import org.apache.hadoop.util.ReflectionUtils;
|
|
|
+import org.apache.hadoop.util.StringUtils;
|
|
|
import org.apache.hadoop.yarn.YarnException;
|
|
|
import org.apache.hadoop.yarn.api.records.ApplicationId;
|
|
|
import org.apache.hadoop.yarn.api.records.ContainerId;
|
|
@@ -49,6 +52,7 @@ import org.apache.hadoop.yarn.service.CompositeService;
|
|
|
import org.apache.hadoop.yarn.service.Service;
|
|
|
|
|
|
public class NodeManager extends CompositeService {
|
|
|
+ private static final Log LOG = LogFactory.getLog(NodeManager.class);
|
|
|
protected final NodeManagerMetrics metrics = NodeManagerMetrics.create();
|
|
|
|
|
|
public NodeManager() {
|
|
@@ -185,6 +189,7 @@ public class NodeManager extends CompositeService {
|
|
|
}
|
|
|
|
|
|
public static void main(String[] args) {
|
|
|
+ StringUtils.startupShutdownMessage(NodeManager.class, args, LOG);
|
|
|
NodeManager nodeManager = new NodeManager();
|
|
|
YarnConfiguration conf = new YarnConfiguration();
|
|
|
nodeManager.init(conf);
|