[minor] Minor code clean
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 28cdb3e..16242be 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
@@ -26,7 +26,7 @@
import java.util.concurrent.ExecutorService;
/**
- * Factory class for creating schedulers except RemoteScheduler as RemoteScheudler runs in
+ * Factory class for creating schedulers except RemoteScheduler as RemoteScheduler runs in
* zeppelin server process instead of interpreter process.
*
*/
@@ -116,5 +116,4 @@
public ExecutorService getExecutor() {
return executor;
}
-
}
diff --git a/zeppelin-zengine/src/main/java/org/apache/zeppelin/interpreter/remote/RemoteInterpreter.java b/zeppelin-zengine/src/main/java/org/apache/zeppelin/interpreter/remote/RemoteInterpreter.java
index a03aacf..297024a 100644
--- a/zeppelin-zengine/src/main/java/org/apache/zeppelin/interpreter/remote/RemoteInterpreter.java
+++ b/zeppelin-zengine/src/main/java/org/apache/zeppelin/interpreter/remote/RemoteInterpreter.java
@@ -389,14 +389,10 @@
@Override
public Scheduler getScheduler() {
- int maxConcurrency = Integer.parseInt(
- getProperty("zeppelin.interpreter.max.poolsize",
- ZeppelinConfiguration.ConfVars.ZEPPELIN_INTERPRETER_MAX_POOL_SIZE.getIntValue() + ""));
// one session own one Scheduler, so that when one session is closed, all the jobs/paragraphs
// running under the scheduler of this session will be aborted.
Scheduler s = new RemoteScheduler(
- RemoteInterpreter.class.getSimpleName() + "-" + getInterpreterGroup().getId() + "-"
- + sessionId,
+ RemoteInterpreter.class.getSimpleName() + getInterpreterGroup().getId(),
SchedulerFactory.singleton().getExecutor(),
this);
return SchedulerFactory.singleton().createOrGetScheduler(s);
