minor code refacotring

This commit is contained in:
Jeff Zhang 2021-06-17 08:45:39 +08:00
parent a7dca0fd35
commit ee8d11b8fd

View file

@ -259,23 +259,6 @@ public class JupyterKernelInterpreter extends AbstractInterpreter {
}
}
private File buildBootstrapScriptFile(int kernelPort) throws IOException {
StringBuilder builder = new StringBuilder();
if (condaEnv != null) {
builder.append("source " + condaEnv + "/bin/activate\n");
}
builder.append(pythonExecutable);
builder.append(" " + kernelWorkDir.getAbsolutePath() + "/kernel_server.py");
builder.append(" " + getKernelName());
builder.append(" " + kernelPort);
File scriptFile = Files.createTempFile("zeppelin_jupyter_", ".sh").toFile();
try (FileWriter out = new FileWriter(scriptFile)) {
IOUtils.write(builder.toString(), out);
}
scriptFile.setExecutable(true);
return scriptFile;
}
protected Map<String, String> setupKernelEnv() throws IOException {
return EnvironmentUtils.getProcEnvironment();
}