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

Fix test failure, fixes based on discussion

Browse source
This commit is contained in:
karuppayya 2016-01-24 21:24:16 +05:30
parent 431cc797c7
commit 6293781225
3 changed files with 2 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
zeppelin-interpreter/src/main/java/org/apache/zeppelin/interpreter/remote/RemoteInterpreter.java
View file

@ -91,6 +91,7 @@ public class RemoteInterpreter extends Interpreter {
this.interpreterPath = interpreterPath;
this.env = env;
this.connectTimeout = connectTimeout;
this.maxPoolSize = 10;
this.remoteInterpreterProcessListener = remoteInterpreterProcessListener;
}

1
zeppelin-interpreter/src/main/java/org/apache/zeppelin/interpreter/remote/RemoteInterpreterServer.java
View file

@ -263,6 +263,7 @@ public class RemoteInterpreterServer
private Interpreter interpreter;
private String script;
private InterpreterContext context;
private Map<String, Object> infos;
public InterpretJob(
String jobId,

1
zeppelin-interpreter/src/main/java/org/apache/zeppelin/scheduler/Job.java
View file

@ -86,7 +86,6 @@ public abstract class Job {
private transient Throwable exception;
private transient JobListener listener;
private long progressUpdateIntervalMs;
protected Map<String, Object> infos;
public Job(String jobName, JobListener listener, long progressUpdateIntervalMs) {
this.jobName = jobName;