You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@zeppelin.apache.org by pd...@apache.org on 2021/10/25 07:23:05 UTC
[zeppelin] 01/04: Close interpretergroup session if interpreter
creation failed
This is an automated email from the ASF dual-hosted git repository.
pdallig pushed a commit to branch recover_interpretergroup
in repository https://gitbox.apache.org/repos/asf/zeppelin.git
commit c11f108c0235fa42362ac4e972090db843796b19
Author: Philipp Dallig <ph...@gmail.com>
AuthorDate: Tue Oct 19 15:51:50 2021 +0200
Close interpretergroup session if interpreter creation failed
---
.../org/apache/zeppelin/interpreter/remote/RemoteInterpreter.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git a/zeppelin-zengine/src/main/java/org/apache/zeppelin/interpreter/remote/RemoteInterpreter.java b/zeppelin-zengine/src/main/java/org/apache/zeppelin/interpreter/remote/RemoteInterpreter.java
index 02f1b62..16e47c3 100644
--- a/zeppelin-zengine/src/main/java/org/apache/zeppelin/interpreter/remote/RemoteInterpreter.java
+++ b/zeppelin-zengine/src/main/java/org/apache/zeppelin/interpreter/remote/RemoteInterpreter.java
@@ -30,7 +30,6 @@ import org.apache.zeppelin.interpreter.Interpreter;
import org.apache.zeppelin.interpreter.InterpreterContext;
import org.apache.zeppelin.interpreter.InterpreterException;
import org.apache.zeppelin.interpreter.InterpreterResult;
-import org.apache.zeppelin.interpreter.LifecycleManager;
import org.apache.zeppelin.interpreter.ManagedInterpreterGroup;
import org.apache.zeppelin.interpreter.thrift.InterpreterCompletion;
import org.apache.zeppelin.interpreter.thrift.RemoteInterpreterContext;
@@ -126,6 +125,9 @@ public class RemoteInterpreter extends Interpreter {
((RemoteInterpreter) interpreter).internal_create();
}
} catch (IOException e) {
+ LOGGER.error("Interpreter creation failed", e);
+ interpreterProcess = null;
+ getInterpreterGroup().close(sessionId);
throw new InterpreterException(e);
}
}