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

Update NoteTest

Browse source
This commit is contained in:
Lee moon soo 2016-06-15 23:40:19 -07:00
parent e54d633ef3
commit 5bef173af7
1 changed files with 5 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
zeppelin-zengine/src/test/java/org/apache/zeppelin/notebook/NoteTest.java
View file

@ -54,13 +54,16 @@ public class NoteTest {
@Mock
Scheduler scheduler;
@Mock
NoteEventListener noteEventListener;
@Test
public void runNormalTest() {
when(replLoader.get("spark")).thenReturn(interpreter);
when(interpreter.getScheduler()).thenReturn(scheduler);
String pText = "%spark sc.version";
Note note = new Note(repo, replLoader, jobListenerFactory, index, credentials);
Note note = new Note(repo, replLoader, jobListenerFactory, index, credentials, noteEventListener);
Paragraph p = note.addParagraph();
p.setText(pText);
note.run(p.getId());
@ -79,7 +82,7 @@ public class NoteTest {
when(interpreter.getScheduler()).thenReturn(scheduler);
String pText = "%mysql show databases";
Note note = new Note(repo, replLoader, jobListenerFactory, index, credentials);
Note note = new Note(repo, replLoader, jobListenerFactory, index, credentials, noteEventListener);
Paragraph p = note.addParagraph();
p.setText(pText);
note.run(p.getId());