From 4e926d44b044aa3c3f8cdb78ceae90089d1c7011 Mon Sep 17 00:00:00 2001 From: Jeff Zhang Date: Fri, 28 Sep 2018 16:48:21 +0800 Subject: [PATCH] ZEPPELIN-3800. Allow to configure scheduler thread pool size --- .../org/apache/zeppelin/conf/ZeppelinConfiguration.java | 2 ++ .../org/apache/zeppelin/scheduler/SchedulerFactory.java | 6 ++++-- 2 files changed, 6 insertions(+), 2 deletions(-) diff --git a/zeppelin-interpreter/src/main/java/org/apache/zeppelin/conf/ZeppelinConfiguration.java b/zeppelin-interpreter/src/main/java/org/apache/zeppelin/conf/ZeppelinConfiguration.java index 2b2f3b6fac6..a415b5086a0 100644 --- a/zeppelin-interpreter/src/main/java/org/apache/zeppelin/conf/ZeppelinConfiguration.java +++ b/zeppelin-interpreter/src/main/java/org/apache/zeppelin/conf/ZeppelinConfiguration.java @@ -780,6 +780,8 @@ public enum ConfVars { ZEPPELIN_INTERPRETER_LIFECYCLE_MANAGER_TIMEOUT_THRESHOLD( "zeppelin.interpreter.lifecyclemanager.timeout.threshold", 3600000L), + ZEPPELIN_INTERPRETER_SCHEDULER_POOL_SIZE("zeppelin.scheduler.threadpool.size", 100), + ZEPPELIN_OWNER_ROLE("zeppelin.notebook.default.owner.username", ""), ZEPPELIN_NOTEBOOK_GIT_REMOTE_URL("zeppelin.notebook.git.remote.url", ""), diff --git a/zeppelin-interpreter/src/main/java/org/apache/zeppelin/scheduler/SchedulerFactory.java b/zeppelin-interpreter/src/main/java/org/apache/zeppelin/scheduler/SchedulerFactory.java index ab8cd66f5ce..8b525e8d618 100644 --- a/zeppelin-interpreter/src/main/java/org/apache/zeppelin/scheduler/SchedulerFactory.java +++ b/zeppelin-interpreter/src/main/java/org/apache/zeppelin/scheduler/SchedulerFactory.java @@ -57,8 +57,10 @@ public static SchedulerFactory singleton() { SchedulerFactory() { ZeppelinConfiguration zConf = ZeppelinConfiguration.create(); - executor = ExecutorFactory.singleton().createOrGet(SCHEDULER_EXECUTOR_NAME, - zConf.getInt("zeppelin.scheduler.threadpool.size", 100)); + int threadPoolSize = + zConf.getInt(ZeppelinConfiguration.ConfVars.ZEPPELIN_INTERPRETER_SCHEDULER_POOL_SIZE); + LOGGER.info("Scheduler Thread Pool Size: " + threadPoolSize); + executor = ExecutorFactory.singleton().createOrGet(SCHEDULER_EXECUTOR_NAME, threadPoolSize); } public void destroy() {