Skip to content

Commit 42d92ac

Browse files
karuppayyaKarup
authored andcommitted
Fix test
Signed-off-by: karuppayya <[email protected]>
1 parent d4e54e8 commit 42d92ac

1 file changed

Lines changed: 1 addition & 11 deletions

File tree

spark/src/test/java/org/apache/zeppelin/spark/SparkInterpreterTest.java

Lines changed: 1 addition & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -314,17 +314,7 @@ public void testParagraphUrls() {
314314
new AngularObjectRegistry(intpGroup.getId(), null),
315315
new LocalResourcePool("id"),
316316
new LinkedList<InterpreterContextRunner>(),
317-
new InterpreterOutput(new InterpreterOutputListener() {
318-
@Override
319-
public void onAppend(InterpreterOutput out, byte[] line) {
320-
321-
}
322-
323-
@Override
324-
public void onUpdate(InterpreterOutput out, byte[] output) {
325-
326-
}
327-
}));
317+
new InterpreterOutput(null));
328318
repl.interpret("sc.parallelize(1 to 10).map(x => {x}).collect", intpCtx);
329319
Map<String, String> paraInfos = paraIdToInfosMap.get(intpCtx.getParagraphId());
330320
String jobUrl = null;

0 commit comments

Comments
 (0)