2015-06-22 39 views
0

我已经后续错误/警告:火花集群:我想知道以下错误和可能原因的含义:

1)WARN AkkaRpcEndpointRef:错误发送消息[消息=心跳(2,[Lscala.Tuple2; @ 58149ee3,BlockManagerId(2,192.168.0.171,49714))]在1次尝试 java.util.concurrent.TimeoutException:期货后[120秒]

2)ERROR超时CoarseGrainedExecutorBackend:Driver 192.168.0.131:41837 disassociated!关机。

我在4台机器的集群中运行Spark(v。1.4.0)应用程序,其中驱动程序的工作内存(每GB 8 GB)的内存较少(4 GB)。由于工作量的原因,司机是否有可能产生错误?

+0

请参阅:http://apache-spark-user-list.1001560.n3.nabble.com/CoarseGrainedExecutorBackend-Driver-Disassociated-td9059.html –

回答

1

驱动程序无法响应执行程序,因为它在计算过程中处于压力之下。 问题只是通过向驱动程序添加mroe RAM来解决。