From 72e9d62406b8525ac81deef7a04165be03441e02 Mon Sep 17 00:00:00 2001 From: Alexander Bezzubov Date: Fri, 17 Jun 2016 13:59:50 +0900 Subject: [PATCH] Python: switch to FIFO scheduler 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 --- .../java/org/apache/zeppelin/python/PythonInterpreter.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/python/src/main/java/org/apache/zeppelin/python/PythonInterpreter.java b/python/src/main/java/org/apache/zeppelin/python/PythonInterpreter.java index 46dc1b2dff0..b1da98192d4 100644 --- a/python/src/main/java/org/apache/zeppelin/python/PythonInterpreter.java +++ b/python/src/main/java/org/apache/zeppelin/python/PythonInterpreter.java @@ -161,8 +161,8 @@ public int getProgress(InterpreterContext context) { @Override public Scheduler getScheduler() { - return SchedulerFactory.singleton().createOrGetParallelScheduler( - PythonInterpreter.class.getName() + this.hashCode(), 10); + return SchedulerFactory.singleton().createOrGetFIFOScheduler( + PythonInterpreter.class.getName() + this.hashCode()); } @Override