答复: bug in Worker.scala, ExecutorRunner is not serializable

[Huangguowei]

Not error in normal case.

But if I want to ask Worker through akkaUrl to get executors status, it will 
cause Exception.


发件人: 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<mailto: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.