diff --git a/zeppelin-zengine/src/main/java/org/apache/zeppelin/interpreter/InterpreterFactory.java b/zeppelin-zengine/src/main/java/org/apache/zeppelin/interpreter/InterpreterFactory.java index cf6f083dc6..c62b5eee6d 100644 --- a/zeppelin-zengine/src/main/java/org/apache/zeppelin/interpreter/InterpreterFactory.java +++ b/zeppelin-zengine/src/main/java/org/apache/zeppelin/interpreter/InterpreterFactory.java @@ -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; diff --git a/zeppelin-zengine/src/main/java/org/apache/zeppelin/notebook/Notebook.java b/zeppelin-zengine/src/main/java/org/apache/zeppelin/notebook/Notebook.java index 0bddf9e6ff..75b3ea4dbe 100644 --- a/zeppelin-zengine/src/main/java/org/apache/zeppelin/notebook/Notebook.java +++ b/zeppelin-zengine/src/main/java/org/apache/zeppelin/notebook/Notebook.java @@ -153,7 +153,13 @@ public class Notebook implements NoteEventListener { */ public Note createNote(List 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);