|
@@ -27,7 +27,9 @@ import org.apache.commons.logging.Log;
|
|
import org.apache.commons.logging.LogFactory;
|
|
import org.apache.commons.logging.LogFactory;
|
|
import org.apache.hadoop.classification.InterfaceAudience.Private;
|
|
import org.apache.hadoop.classification.InterfaceAudience.Private;
|
|
import org.apache.hadoop.conf.Configuration;
|
|
import org.apache.hadoop.conf.Configuration;
|
|
|
|
+import org.apache.hadoop.metrics2.MetricsSystem;
|
|
import org.apache.hadoop.metrics2.lib.DefaultMetricsSystem;
|
|
import org.apache.hadoop.metrics2.lib.DefaultMetricsSystem;
|
|
|
|
+import org.apache.hadoop.metrics2.source.JvmMetrics;
|
|
import org.apache.hadoop.security.SecurityUtil;
|
|
import org.apache.hadoop.security.SecurityUtil;
|
|
import org.apache.hadoop.util.ReflectionUtils;
|
|
import org.apache.hadoop.util.ReflectionUtils;
|
|
import org.apache.hadoop.util.StringUtils;
|
|
import org.apache.hadoop.util.StringUtils;
|
|
@@ -449,7 +451,8 @@ public class ResourceManager extends CompositeService implements Recoverable {
|
|
}
|
|
}
|
|
|
|
|
|
startWepApp();
|
|
startWepApp();
|
|
- DefaultMetricsSystem.initialize("ResourceManager");
|
|
|
|
|
|
+ MetricsSystem ms = DefaultMetricsSystem.initialize("ResourceManager");
|
|
|
|
+ JvmMetrics.create("ResourceManager", null, ms);
|
|
try {
|
|
try {
|
|
rmDTSecretManager.startThreads();
|
|
rmDTSecretManager.startThreads();
|
|
} catch(IOException ie) {
|
|
} catch(IOException ie) {
|