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

add InterpreterForNote testcase

Browse source
This commit is contained in:
astroshim 2016-10-04 23:53:09 +09:00
parent fa45bb55b2
commit 36f564273e
1 changed files with 21 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

24
zeppelin-zengine/src/test/java/org/apache/zeppelin/notebook/NotebookTest.java
View file

@ -696,7 +696,7 @@ public class NotebookTest implements JobListenerFactory{
}
@Test
public void testPerSessionInterpreter() throws IOException {
public void testInterpreterForNote() throws IOException {
// create two notes
Note note1 = notebook.createNote(null);
Paragraph p1 = note1.addParagraph();
@ -707,7 +707,7 @@ public class NotebookTest implements JobListenerFactory{
p1.setText("getId");
p2.setText("getId");
// run per note session disabled
// run per note session disabled (shared mode)
note1.run(p1.getId());
note2.run(p2.getId());
@ -717,9 +717,10 @@ public class NotebookTest implements JobListenerFactory{
assertEquals(p1.getResult().message(), p2.getResult().message());
// restart interpreter with per note session enabled
// restart interpreter with scoped(per note session) mode enabled
for (InterpreterSetting setting : notebook.getInterpreterFactory().getInterpreterSettings(note1.getId())) {
setting.getOption().setPerNoteSession(true);
setting.getOption().setPerNoteProcess(false);
notebook.getInterpreterFactory().restart(setting.getId());
}
@ -732,6 +733,23 @@ public class NotebookTest implements JobListenerFactory{
assertNotEquals(p1.getResult().message(), p2.getResult().message());
// restart interpreter with isolated(per note process) mode enabled
for (InterpreterSetting setting : notebook.getInterpreterFactory().getInterpreterSettings(note1.getId())) {
setting.getOption().setPerNoteSession(false);
setting.getOption().setPerNoteProcess(true);
notebook.getInterpreterFactory().restart(setting.getId());
}
// run per note process enabled
note1.run(p1.getId());
note2.run(p2.getId());
while (p1.getStatus() != Status.FINISHED) Thread.yield();
while (p2.getStatus() != Status.FINISHED) Thread.yield();
assertNotEquals(p1.getResult().message(), p2.getResult().message());
notebook.removeNote(note1.getId(), null);
notebook.removeNote(note2.getId(), null);
}