Maybe we should add some inline comment explaining why it is ok for that message to be not serializable.
On Thu, Sep 17, 2015 at 4:08 AM, Huangguowei <huangguo...@huawei.com> wrote: > Thanks for your reply. I just want to do some monitors, never mind! > > > > *发件人:* Shixiong Zhu [mailto:zsxw...@gmail.com] > *发送时间:* 2015年9月17日 17:23 > *收件人:* Huangguowei; dev@spark.apache.org > *主题:* Re: bug in Worker.scala, ExecutorRunner is not serializable > > > > 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. > > > > > > >
