Elgato_dark/zeppelin
1
0
Fork 0
mirror of https://github.com/apache/zeppelin synced 2026-05-24 09:38:26 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

print processes

Browse source
This commit is contained in:
Lee moon soo 2016-06-17 00:17:16 -07:00
parent 5b5f6c816c
commit eaa68c6be8
1 changed files with 27 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

27
zeppelin-server/src/test/java/org/apache/zeppelin/rest/ZeppelinSparkClusterTest.java
View file

@ -24,7 +24,12 @@ import java.util.HashMap;
import java.util.List;
import java.util.Map;
import org.apache.commons.exec.CommandLine;
import org.apache.commons.exec.DefaultExecutor;
import org.apache.commons.exec.ExecuteWatchdog;
import org.apache.commons.exec.PumpStreamHandler;
import org.apache.commons.io.FileUtils;
import org.apache.commons.io.output.ByteArrayOutputStream;
import org.apache.zeppelin.interpreter.InterpreterSetting;
import org.apache.zeppelin.notebook.Note;
import org.apache.zeppelin.notebook.Paragraph;
@ -101,6 +106,7 @@ public class ZeppelinSparkClusterTest extends AbstractTestRestApi {
);
note.run(p.getId());
waitForFinish(p);
ps();
System.err.println("sparkRTest=" + p.getResult().message());
assertEquals(Status.FINISHED, p.getStatus());
assertEquals("[1] 3", p.getResult().message());
@ -108,6 +114,27 @@ public class ZeppelinSparkClusterTest extends AbstractTestRestApi {
ZeppelinServer.notebook.removeNote(note.id());
}
@Test
public void testPs() {
ps();
}
private void ps() {
CommandLine cmdLine = CommandLine.parse("ps aux");
DefaultExecutor executor = new DefaultExecutor();
ByteArrayOutputStream out = new ByteArrayOutputStream();
executor.setStreamHandler(new PumpStreamHandler(out, out));
try {
executor.execute(cmdLine);
} catch (IOException e) {
e.printStackTrace();
}
System.err.println("ps>>>>>>>>>>>>>>>>>\n" + new String(out.toByteArray()) +
"\n<<<<<<<<<<<<<<<<<<");
}
@Test
public void pySparkTest() throws IOException {
// create new note