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 style

Browse source
This commit is contained in:
Lee moon soo 2016-06-08 13:47:35 -07:00
parent 1dc4409464
commit bfcdf347dd
2 changed files with 10 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
zeppelin-zengine/src/main/java/org/apache/zeppelin/interpreter/InterpreterFactory.java
View file

@ -927,10 +927,11 @@ public class InterpreterFactory implements InterpreterGroupFactory {
updatePropertiesFromRegisteredInterpreter(property, className);
LazyOpenInterpreter intp = new LazyOpenInterpreter(new RemoteInterpreter(
RemoteInterpreter remoteInterpreter = new RemoteInterpreter(
property, noteId, className, conf.getInterpreterRemoteRunnerPath(),
interpreterPath, localRepoPath, connectTimeout,
maxPoolSize, remoteInterpreterProcessListener, appEventListener);
maxPoolSize, remoteInterpreterProcessListener, appEventListener)
remoteInterpreter.setEnv(env);
LazyOpenInterpreter intp = new LazyOpenInterpreter(remoteInterpreter);
return intp;

8
zeppelin-zengine/src/main/java/org/apache/zeppelin/notebook/Notebook.java
View file

@ -153,7 +153,13 @@ public class Notebook implements NoteEventListener {
*/
public Note createNote(List<String> interpreterIds) throws IOException {
NoteInterpreterLoader intpLoader = new NoteInterpreterLoader(replFactory);
Note note = new Note(notebookRepo, intpLoader, jobListenerFactory, notebookIndex, credentials, this);
Note note = new Note(
notebookRepo,
intpLoader,
jobListenerFactory,
notebookIndex,
credentials,
this);
intpLoader.setNoteId(note.id());
synchronized (notes) {
notes.put(note.id(), note);