Skip to content

Commit f94125c

Browse files
ZEPPELIN-1454: read from file-system after saving
1 parent b8755eb commit f94125c

File tree

1 file changed

+15
-11
lines changed

1 file changed

+15
-11
lines changed

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

Lines changed: 15 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -839,17 +839,21 @@ public void setPropertyAndRestart(String id, InterpreterOption option, Propertie
839839
synchronized (interpreterSettings) {
840840
InterpreterSetting intpsetting = interpreterSettings.get(id);
841841
if (intpsetting != null) {
842-
843-
stopJobAllInterpreter(intpsetting);
844-
845-
intpsetting.closeAndRmoveAllInterpreterGroups();
846-
847-
intpsetting.setOption(option);
848-
intpsetting.setProperties(properties);
849-
intpsetting.setDependencies(dependencies);
850-
851-
loadInterpreterDependencies(intpsetting);
852-
saveToFile();
842+
try {
843+
stopJobAllInterpreter(intpsetting);
844+
845+
intpsetting.closeAndRmoveAllInterpreterGroups();
846+
intpsetting.setOption(option);
847+
intpsetting.setProperties(properties);
848+
intpsetting.setDependencies(dependencies);
849+
loadInterpreterDependencies(intpsetting);
850+
851+
saveToFile();
852+
} catch (Exception e) {
853+
throw e;
854+
} finally {
855+
loadFromFile();
856+
}
853857
} else {
854858
throw new InterpreterException("Interpreter setting id " + id + " not found");
855859
}

0 commit comments

Comments
 (0)