You are viewing a plain text version of this content. The canonical link for it is here.
Posted to common-commits@hadoop.apache.org by wa...@apache.org on 2017/05/22 20:48:49 UTC
[45/50] hadoop git commit: YARN-6627. Use deployed webapp folder to
launch new YARN UI. Contributed by Sunil G
YARN-6627. Use deployed webapp folder to launch new YARN UI. Contributed by Sunil G
Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo
Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/e135c0b2
Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/e135c0b2
Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/e135c0b2
Branch: refs/heads/YARN-5734
Commit: e135c0b20794705dabf86a296d934eb8df02a774
Parents: 9855225
Author: Jian He <ji...@apache.org>
Authored: Fri May 19 20:12:06 2017 -0700
Committer: Jian He <ji...@apache.org>
Committed: Fri May 19 20:14:03 2017 -0700
----------------------------------------------------------------------
.../resources/assemblies/hadoop-yarn-dist.xml | 5 ++-
.../server/resourcemanager/ResourceManager.java | 34 ++++++++++++++------
2 files changed, 29 insertions(+), 10 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hadoop/blob/e135c0b2/hadoop-assemblies/src/main/resources/assemblies/hadoop-yarn-dist.xml
----------------------------------------------------------------------
diff --git a/hadoop-assemblies/src/main/resources/assemblies/hadoop-yarn-dist.xml b/hadoop-assemblies/src/main/resources/assemblies/hadoop-yarn-dist.xml
index 05e1a93..74ce9bc 100644
--- a/hadoop-assemblies/src/main/resources/assemblies/hadoop-yarn-dist.xml
+++ b/hadoop-assemblies/src/main/resources/assemblies/hadoop-yarn-dist.xml
@@ -180,7 +180,7 @@
</fileSet>
<fileSet>
<directory>hadoop-yarn/hadoop-yarn-ui/target/hadoop-yarn-ui-${project.version}</directory>
- <outputDirectory>/share/hadoop/${hadoop.component}/webapps/rm</outputDirectory>
+ <outputDirectory>/share/hadoop/${hadoop.component}/webapps/ui2</outputDirectory>
<includes>
<include>**/*</include>
</includes>
@@ -188,6 +188,9 @@
</fileSets>
<moduleSets>
<moduleSet>
+ <excludes>
+ <exclude>org.apache.hadoop:hadoop-yarn-ui</exclude>
+ </excludes>
<binaries>
<outputDirectory>share/hadoop/${hadoop.component}</outputDirectory>
<includeDependencies>false</includeDependencies>
http://git-wip-us.apache.org/repos/asf/hadoop/blob/e135c0b2/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/ResourceManager.java
----------------------------------------------------------------------
diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/ResourceManager.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/ResourceManager.java
index 1f5e8cd..8f2c121 100644
--- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/ResourceManager.java
+++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/ResourceManager.java
@@ -113,6 +113,8 @@ import org.apache.zookeeper.server.auth.DigestAuthenticationProvider;
import org.eclipse.jetty.webapp.WebAppContext;
import com.google.common.annotations.VisibleForTesting;
+
+import java.io.FileNotFoundException;
import java.io.IOException;
import java.io.InputStream;
import java.io.PrintStream;
@@ -1068,33 +1070,47 @@ public class ResourceManager extends CompositeService implements Recoverable {
WebAppContext uiWebAppContext = null;
if (getConfig().getBoolean(YarnConfiguration.YARN_WEBAPP_UI2_ENABLE,
YarnConfiguration.DEFAULT_YARN_WEBAPP_UI2_ENABLE)) {
- String webPath = UI2_WEBAPP_NAME;
String onDiskPath = getConfig()
.get(YarnConfiguration.YARN_WEBAPP_UI2_WARFILE_PATH);
+ uiWebAppContext = new WebAppContext();
+ uiWebAppContext.setContextPath(UI2_WEBAPP_NAME);
+
if (null == onDiskPath) {
String war = "hadoop-yarn-ui-" + VersionInfo.getVersion() + ".war";
URLClassLoader cl = (URLClassLoader) ClassLoader.getSystemClassLoader();
URL url = cl.findResource(war);
if (null == url) {
- onDiskPath = "";
+ onDiskPath = getWebAppsPath("ui2");
} else {
onDiskPath = url.getFile();
}
-
- LOG.info(
- "New web UI war file name:" + war + ", and path:" + onDiskPath);
}
-
- uiWebAppContext = new WebAppContext();
- uiWebAppContext.setContextPath(webPath);
- uiWebAppContext.setWar(onDiskPath);
+ if (onDiskPath == null || onDiskPath.isEmpty()) {
+ LOG.error("No war file or webapps found for ui2 !");
+ } else {
+ if (onDiskPath.endsWith(".war")) {
+ uiWebAppContext.setWar(onDiskPath);
+ LOG.info("Using war file at: " + onDiskPath);
+ } else {
+ uiWebAppContext.setResourceBase(onDiskPath);
+ LOG.info("Using webapps at: " + onDiskPath);
+ }
+ }
}
webApp = builder.start(new RMWebApp(this), uiWebAppContext);
}
+ private String getWebAppsPath(String appName) {
+ URL url = getClass().getClassLoader().getResource("webapps/" + appName);
+ if (url == null) {
+ return "";
+ }
+ return url.toString();
+ }
+
/**
* Helper method to create and init {@link #activeServices}. This creates an
* instance of {@link RMActiveServices} and initializes it.
---------------------------------------------------------------------
To unsubscribe, e-mail: common-commits-unsubscribe@hadoop.apache.org
For additional commands, e-mail: common-commits-help@hadoop.apache.org