Update testcase

This commit is contained in:
Lee moon soo 2016-11-22 19:19:55 -08:00
parent b01d70ff1d
commit 26e201af5d
2 changed files with 4 additions and 4 deletions

View file

@ -173,7 +173,7 @@ public class InterpreterRestApiTest extends AbstractTestRestApi {
while (p.getStatus() != Status.FINISHED) {
Thread.sleep(100);
}
assertEquals(p.getResult().message(), getSimulatedMarkdownResult("markdown"));
assertEquals(p.getResult().message().get(0).getData(), getSimulatedMarkdownResult("markdown"));
// restart interpreter
for (InterpreterSetting setting : ZeppelinServer.notebook.getInterpreterFactory().getInterpreterSettings(note.getId())) {
@ -195,7 +195,7 @@ public class InterpreterRestApiTest extends AbstractTestRestApi {
while (p.getStatus() != Status.FINISHED) {
Thread.sleep(100);
}
assertEquals(p.getResult().message(), getSimulatedMarkdownResult("markdown restarted"));
assertEquals(p.getResult().message().get(0).getData(), getSimulatedMarkdownResult("markdown restarted"));
//cleanup
ZeppelinServer.notebook.removeNote(note.getId(), anonymous);
}
@ -217,7 +217,7 @@ public class InterpreterRestApiTest extends AbstractTestRestApi {
while (p.getStatus() != Status.FINISHED) {
Thread.sleep(100);
}
assertEquals(p.getResult().message(), getSimulatedMarkdownResult("markdown"));
assertEquals(p.getResult().message().get(0).getData(), getSimulatedMarkdownResult("markdown"));
// get md interpreter
InterpreterSetting mdIntpSetting = null;

View file

@ -180,7 +180,7 @@ public class ZeppelinSparkClusterTest extends AbstractTestRestApi {
p.setAuthenticationInfo(anonymous);
note.run(p.getId());
waitForFinish(p);
System.err.println("sparkRTest=" + p.getResult().message());
System.err.println("sparkRTest=" + p.getResult().message().get(0).getData());
assertEquals(Status.FINISHED, p.getStatus());
assertEquals("[1] 3", p.getResult().message().get(0).getData());
}