diff --git a/spark/src/main/java/org/apache/zeppelin/spark/PySparkInterpreter.java b/spark/src/main/java/org/apache/zeppelin/spark/PySparkInterpreter.java index 152f70cf6e9..ea0054188ac 100644 --- a/spark/src/main/java/org/apache/zeppelin/spark/PySparkInterpreter.java +++ b/spark/src/main/java/org/apache/zeppelin/spark/PySparkInterpreter.java @@ -91,7 +91,12 @@ public class PySparkInterpreter extends Interpreter implements ExecuteResultHand public PySparkInterpreter(Properties property) { super(property); - scriptPath = System.getProperty("java.io.tmpdir") + "/zeppelin_pyspark.py"; + try { + File scriptFile = File.createTempFile("zeppelin_pyspark-", ".py"); + scriptPath = scriptFile.getAbsolutePath(); + } catch (IOException e) { + throw new InterpreterException(e); + } } private void createPythonScript() { @@ -235,6 +240,7 @@ private int findRandomOpenPortOnAllLocalInterfaces() { @Override public void close() { executor.getWatchdog().destroyProcess(); + new File(scriptPath).delete(); gatewayServer.shutdown(); } diff --git a/spark/src/main/java/org/apache/zeppelin/spark/ZeppelinR.java b/spark/src/main/java/org/apache/zeppelin/spark/ZeppelinR.java index 8d92c968f50..93a3bcb5899 100644 --- a/spark/src/main/java/org/apache/zeppelin/spark/ZeppelinR.java +++ b/spark/src/main/java/org/apache/zeppelin/spark/ZeppelinR.java @@ -111,8 +111,12 @@ public ZeppelinR(String rCmdPath, String libPath, int sparkRBackendPort) { this.rCmdPath = rCmdPath; this.libPath = libPath; this.port = sparkRBackendPort; - scriptPath = System.getProperty("java.io.tmpdir") + "/zeppelin_sparkr.R"; - + try { + File scriptFile = File.createTempFile("zeppelin_sparkr-", ".R"); + scriptPath = scriptFile.getAbsolutePath(); + } catch (IOException e) { + throw new InterpreterException(e); + } } /**