Elgato_dark/zeppelin
1
0
Fork 0
mirror of https://github.com/apache/zeppelin synced 2026-05-24 09:38:26 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

Python: switch to FIFO scheduler

Browse source 
In current implementation `.interpret()` is not thread-safe and so in
parallel one (esp on empty or graph paragraphs) 'Run All' fails with NPE in logs
This commit is contained in:
Alexander Bezzubov 2016-06-17 13:59:50 +09:00
parent ff197d0622
commit 72e9d62406
1 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
python/src/main/java/org/apache/zeppelin/python/PythonInterpreter.java
View file

@ -161,8 +161,8 @@ public class PythonInterpreter extends Interpreter {
@Override
public Scheduler getScheduler() {
return SchedulerFactory.singleton().createOrGetParallelScheduler(
PythonInterpreter.class.getName() + this.hashCode(), 10);
return SchedulerFactory.singleton().createOrGetFIFOScheduler(
PythonInterpreter.class.getName() + this.hashCode());
}
@Override