This is an automated email from the ASF dual-hosted git repository. aiceflower pushed a commit to branch release-0.9.4 in repository https://gitbox.apache.org/repos/asf/linkis.git
commit 494cf337572eb37642607c2fe6106b77f6971786 Author: jftang <[email protected]> AuthorDate: Wed Jun 3 19:46:49 2020 +0800 Return value type modification --- .../queue/parallelqueue/ParallelSchedulerContextImpl.scala | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/core/scheduler/src/main/scala/com/webank/wedatasphere/linkis/scheduler/queue/parallelqueue/ParallelSchedulerContextImpl.scala b/core/scheduler/src/main/scala/com/webank/wedatasphere/linkis/scheduler/queue/parallelqueue/ParallelSchedulerContextImpl.scala index 83e2086fbb..500fa6cfdd 100644 --- a/core/scheduler/src/main/scala/com/webank/wedatasphere/linkis/scheduler/queue/parallelqueue/ParallelSchedulerContextImpl.scala +++ b/core/scheduler/src/main/scala/com/webank/wedatasphere/linkis/scheduler/queue/parallelqueue/ParallelSchedulerContextImpl.scala @@ -16,8 +16,11 @@ package com.webank.wedatasphere.linkis.scheduler.queue.parallelqueue +import com.webank.wedatasphere.linkis.common.listener.ListenerEventBus import com.webank.wedatasphere.linkis.common.utils.Logging import com.webank.wedatasphere.linkis.scheduler.SchedulerContext +import com.webank.wedatasphere.linkis.scheduler.event.{ScheduleEvent, SchedulerEventListener} +import com.webank.wedatasphere.linkis.scheduler.executer.ExecutorManager /** @@ -48,7 +51,7 @@ class ParallelSchedulerContextImpl(val maxParallelismUsers: Int) extends Schedu } } - override def getOrCreateExecutorManager = null + override def getOrCreateExecutorManager: ExecutorManager = null - override def getOrCreateSchedulerListenerBus = null + override def getOrCreateSchedulerListenerBus: ListenerEventBus[_<: SchedulerEventListener, _<: ScheduleEvent] = null } --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
