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

get correct method

Browse source
This commit is contained in:
Lee moon soo 2015-08-22 15:10:15 -07:00
parent 0c28561f2c
commit 615c395c08
1 changed files with 2 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
spark/src/main/java/org/apache/zeppelin/spark/SparkInterpreter.java
View file

@ -41,6 +41,7 @@ import org.apache.spark.repl.SparkJLineCompletion;
import org.apache.spark.scheduler.ActiveJob;
import org.apache.spark.scheduler.DAGScheduler;
import org.apache.spark.scheduler.Pool;
import org.apache.spark.scheduler.SparkListener;
import org.apache.spark.sql.SQLContext;
import org.apache.spark.ui.jobs.JobProgressListener;
import org.apache.zeppelin.interpreter.Interpreter;
@ -159,7 +160,7 @@ public class SparkInterpreter extends Interpreter {
JobProgressListener pl = new JobProgressListener(context.getConf());
try {
Object listenerBus = context.getClass().getMethod("listenerBus").invoke(context);
Method m = listenerBus.getClass().getMethod("addListener", pl.getClass());
Method m = listenerBus.getClass().getMethod("addListener", SparkListener.class);
m.invoke(listenerBus, pl);
} catch (NoSuchMethodException | SecurityException | IllegalAccessException
| IllegalArgumentException | InvocationTargetException e) {