RequestWorkerState is an internal message between Worker and WorkerWebUI. Since they are in the same process, that's fine. Actually, these are not public APIs. Could you elaborate your use case?
Best Regards, Shixiong Zhu 2015-09-17 16:36 GMT+08:00 Huangguowei <huangguo...@huawei.com>: > > > Is it possible to get Executors status when running an application? > > > > *发件人:* Sean Owen [mailto:so...@cloudera.com] > *发送时间:* 2015年9月17日 15:54 > *收件人:* Huangguowei; Dev > *主题:* Re: bug in Worker.scala, ExecutorRunner is not serializable > > > > Did this cause an error for you? > > > > On Thu, Sep 17, 2015, 8:51 AM Huangguowei <huangguo...@huawei.com> wrote: > > > > In Worker.scala line 480: > > > > case RequestWorkerState => > > sender ! WorkerStateResponse(host, port, workerId, > executors.values.toList, > > finishedExecutors.values.toList, drivers.values.toList, > > finishedDrivers.values.toList, activeMasterUrl, cores, memory, > > coresUsed, memoryUsed, activeMasterWebUiUrl) > > > > The executors’s type is: > > val executors = new HashMap[String, ExecutorRunner] > > > > but ExecutorRunner cannot be Serialized, so if ask RequestWorkerState will > cause java.io.NotSerializableException. > > > > > >
