big-data/hadoop
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

YARN-10161. TestRouterWebServicesREST is corrupting STDOUT. Contributed by Jim Brennan.

Browse Source
This commit is contained in:
Inigo Goiri 2020-02-27 13:18:30 -08:00
parent b420ddeada
commit a43510e21d
2 changed files with 21 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-router/src/test/java/org/apache/hadoop/yarn/server/router/webapp/JavaProcess.java
View File

@ -29,11 +29,12 @@ public class JavaProcess {
private Process process = null; private Process process = null;
public JavaProcess(Class<?> clazz) throws IOException, InterruptedException { public JavaProcess(Class<?> clazz, File output)
this(clazz, null); throws IOException, InterruptedException {
this(clazz, null, output);
} }
public JavaProcess(Class<?> clazz, List<String> addClasspaths) public JavaProcess(Class<?> clazz, List<String> addClasspaths, File output)
throws IOException, InterruptedException { throws IOException, InterruptedException {
String javaHome = System.getProperty("java.home"); String javaHome = System.getProperty("java.home");
String javaBin = String javaBin =
@ -48,7 +49,9 @@ public JavaProcess(Class<?> clazz, List<String> addClasspaths)
String className = clazz.getCanonicalName(); String className = clazz.getCanonicalName();
ProcessBuilder builder = ProcessBuilder builder =
new ProcessBuilder(javaBin, "-cp", classpath, className); new ProcessBuilder(javaBin, "-cp", classpath, className);
builder.inheritIO(); builder.redirectInput(ProcessBuilder.Redirect.INHERIT);
builder.redirectOutput(output);
builder.redirectError(output);
process = builder.start(); process = builder.start();
} }

17
hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-router/src/test/java/org/apache/hadoop/yarn/server/router/webapp/TestRouterWebServicesREST.java
View File

@ -72,6 +72,7 @@
import static org.junit.Assert.assertNotNull; import static org.junit.Assert.assertNotNull;
import static org.junit.Assert.fail; import static org.junit.Assert.fail;
import java.io.File;
import java.io.IOException; import java.io.IOException;
import java.security.PrivilegedExceptionAction; import java.security.PrivilegedExceptionAction;
import java.util.ArrayList; import java.util.ArrayList;
@ -203,17 +204,27 @@ public Boolean get() {
public static void setUp() throws Exception { public static void setUp() throws Exception {
conf = new YarnConfiguration(); conf = new YarnConfiguration();
File baseDir = GenericTestUtils.getTestDir("processes");
baseDir.mkdirs();
String baseName = TestRouterWebServicesREST.class.getSimpleName();
File rmOutput = new File(baseDir, baseName + "-rm.log");
rmOutput.createNewFile();
List<String> addClasspath = new LinkedList<>(); List<String> addClasspath = new LinkedList<>();
addClasspath.add("../hadoop-yarn-server-timelineservice/target/classes"); addClasspath.add("../hadoop-yarn-server-timelineservice/target/classes");
rm = new JavaProcess(ResourceManager.class, addClasspath); rm = new JavaProcess(ResourceManager.class, addClasspath, rmOutput);
rmAddress = getRMWebAppURLWithScheme(conf); rmAddress = getRMWebAppURLWithScheme(conf);
waitWebAppRunning(rmAddress, RM_WEB_SERVICE_PATH); waitWebAppRunning(rmAddress, RM_WEB_SERVICE_PATH);
router = new JavaProcess(Router.class); File routerOutput = new File(baseDir, baseName + "-router.log");
routerOutput.createNewFile();
router = new JavaProcess(Router.class, routerOutput);
routerAddress = getRouterWebAppURLWithScheme(conf); routerAddress = getRouterWebAppURLWithScheme(conf);
waitWebAppRunning(routerAddress, RM_WEB_SERVICE_PATH); waitWebAppRunning(routerAddress, RM_WEB_SERVICE_PATH);
nm = new JavaProcess(NodeManager.class); File nmOutput = new File(baseDir, baseName + "-nm.log");
nmOutput.createNewFile();
nm = new JavaProcess(NodeManager.class, nmOutput);
nmAddress = "http://" + getNMWebAppURLWithoutScheme(conf); nmAddress = "http://" + getNMWebAppURLWithoutScheme(conf);
waitWebAppRunning(nmAddress, "/ws/v1/node"); waitWebAppRunning(nmAddress, "/ws/v1/node");
} }