Re: WARN NettyRpcEndpointRef: Error sending message [message = Heartbeat(driver,...

2015-10-03 Thread Jacek Laskowski
pName("Hello world!") >> conf: org.apache.spark.SparkConf = org.apache.spark.SparkConf@7a8f69d6 >> >> scala> import org.apache.spark.SparkContext >> import org.apache.spark.SparkContext >> >> scala> val sc = new SparkContext(conf) >> ``` >> >> So far s

Re: WARN NettyRpcEndpointRef: Error sending message [message = Heartbeat(driver,...

2015-10-03 Thread Ted Yu
`` > > So far so good. After a while I can see my CPU going up and the REPL > shows up with the WARN: > > ``` > 15/10/03 14:26:03 WARN NettyRpcEndpointRef: Error sending message > [message = Heartbeat(driver,[Lscala.Tuple2;@711362a6 > ,BlockManagerId(driver, > localho

WARN NettyRpcEndpointRef: Error sending message [message = Heartbeat(driver,...

2015-10-03 Thread Jacek Laskowski
parkContext(conf) ``` So far so good. After a while I can see my CPU going up and the REPL shows up with the WARN: ``` 15/10/03 14:26:03 WARN NettyRpcEndpointRef: Error sending message [message = Heartbeat(driver,[Lscala.Tuple2;@711362a6,BlockManagerId(driver, localhost, 50804))] in 1 attempts org