Re: Job Error:Actor not found for: ActorSelection[Anchor(akka.tcp://sparkDriver@130.1.10.108:23600/)

2015-12-25 Thread Saisai Shao
I think SparkContext is thread-safe, you could concurrently submit jobs from different threads, the problem you hit might not relate to this. Can you reproduce this issue each time when you concurrently submit jobs, or is it happened occasionally? BTW, I guess you're using the old version of

Re: Job Error:Actor not found for: ActorSelection[Anchor(akka.tcp://sparkDriver@130.1.10.108:23600/)

2015-12-25 Thread Saisai Shao
> > > -- 原始邮件 -- > *发件人:* "Saisai Shao";<sai.sai.s...@gmail.com>; > *发送时间:* 2015年12月25日(星期五) 下午4:15 > *收件人:* "donhoff_h"<165612...@qq.com>; > *抄送:* "user"<user@spark.apache.org>; > *主题:* Re: Job Error

?????? Job Error:Actor not found for: ActorSelection[Anchor(akka.tcp://sparkDriver@130.1.10.108:23600/)

2015-12-25 Thread donhoff_h
??: "user"<user@spark.apache.org>; : Re: Job Error:Actor not found for: ActorSelection[Anchor(akka.tcp://sparkDriver@130.1.10.108:23600/) I think SparkContext is thread-safe, you could concurrently submit jobs from different threads, the problem you hit might not relate to this.

?????? Job Error:Actor not found for: ActorSelection[Anchor(akka.tcp://sparkDriver@130.1.10.108:23600/)

2015-12-25 Thread donhoff_h
which has 2 cores and 4G memory and with yarn-client mode. -- -- ??: "Saisai Shao";<sai.sai.s...@gmail.com>; : 2015??12??25??(??) 4:15 ??: "donhoff_h"<165612...@qq.com>; : "user"&l

Job Error:Actor not found for: ActorSelection[Anchor(akka.tcp://sparkDriver@130.1.10.108:23600/)

2015-12-24 Thread donhoff_h
Hi,folks I wrote some spark jobs and these jobs could ran successfully when I ran them one by one. But if I ran them concurrently, for example 12 jobs parallel running, I met the following error. Could anybody tell me what cause this? How to solve it? Many Thanks! Exception in thread "main"