gt;
>>> 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: bu
o: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.
>
il.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
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
ossible 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
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
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
Did this cause an error for you?
On Thu, Sep 17, 2015, 8:51 AM Huangguowei wrote:
>
>
> In Worker.scala line 480:
>
>
>
> case RequestWorkerState =>
>
> sender ! WorkerStateResponse(host, port, workerId,
> executors.values.toList,
>
> finishedExecutors.values.toList, drivers.va
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, mem
