[ZEPPELIN-502] change PYTHON_PATH to ZEPPELIN_PYTHON

This commit is contained in:
Hervé RIVIERE 2016-05-19 23:45:11 +02:00
parent c62ac98387
commit e5d0bdbbbb
2 changed files with 8 additions and 8 deletions

View file

@ -47,8 +47,8 @@ public class PythonInterpreter extends Interpreter {
public static final String BOOTSTRAP_PY = "/bootstrap.py";
public static final String BOOTSTRAP_INPUT_PY = "/bootstrap_input.py";
public static final String PYTHON_PATH = "python";
public static final String DEFAULT_PYTHON_PATH = "python";
public static final String ZEPPELIN_PYTHON = "zeppelin.python";
public static final String DEFAULT_ZEPPELIN_PYTHON = "python";
private Integer port;
private GatewayServer gatewayServer;
@ -63,7 +63,7 @@ public class PythonInterpreter extends Interpreter {
"python",
PythonInterpreter.class.getName(),
new InterpreterPropertyBuilder()
.add(PYTHON_PATH, DEFAULT_PYTHON_PATH,
.add(ZEPPELIN_PYTHON, DEFAULT_ZEPPELIN_PYTHON,
"Python directory. Default : python (assume python is in your $PATH)")
.build()
);
@ -80,7 +80,7 @@ public class PythonInterpreter extends Interpreter {
logger.info("Starting Python interpreter .....");
logger.info("Python path is set to:" + property.getProperty(PYTHON_PATH));
logger.info("Python path is set to:" + property.getProperty(ZEPPELIN_PYTHON));
process = getPythonProcess();
@ -177,7 +177,7 @@ public class PythonInterpreter extends Interpreter {
public PythonProcess getPythonProcess() {
if (process == null)
return new PythonProcess(getProperty(PYTHON_PATH));
return new PythonProcess(getProperty(ZEPPELIN_PYTHON));
else
return process;
}

View file

@ -50,8 +50,8 @@ public class PythonInterpreterTest {
Logger logger = LoggerFactory.getLogger(PythonProcess.class);
public static final String PYTHON_PATH = "python";
public static final String DEFAULT_PYTHON_PATH = "python";
public static final String ZEPPELIN_PYTHON = "zeppelin.python";
public static final String DEFAULT_ZEPPELIN_PYTHON = "python";
PythonInterpreter pythonInterpreter = null;
PythonProcess mockPythonProcess;
@ -87,7 +87,7 @@ public class PythonInterpreterTest {
}
Properties properties = new Properties();
properties.put(PYTHON_PATH, DEFAULT_PYTHON_PATH);
properties.put(ZEPPELIN_PYTHON, DEFAULT_ZEPPELIN_PYTHON);
pythonInterpreter = spy(new PythonInterpreter(properties));
when(pythonInterpreter.getPythonProcess()).thenReturn(mockPythonProcess);