0

当从远程actor向spark发送消息时,心跳总是失败:

远程节点的日志:

[信息] [03/23/2015 22:13:33.591] [wtb-akka.remote.default-remote-dispatcher-6] [akka.tcp://wtb@127.0.0.1:2552/system/transports/akkaprotocolmanager .tcp0/akkaProtocol-tcp%3A%2F%2FsparkDriver%40127.0.0.1%3A7777-1] 远程无响应。握手超时或传输故障检测器已触发。

[警告] [03/23/2015 22:13:33.605] [wtb-akka.remote.default-remote-dispatcher-5] [akka.tcp://wtb@127.0.0.1:2552/system/endpointManager/reliableEndpointWriter -akka.tcp%3A%2F%2FsparkDriver%40127.0.0.1%3A7777-0] 与远程系统 [akka.tcp://sparkDriver@127.0.0.1:7777] 的关联失败,地址现在为 [5000] 毫秒. 原因是:[解除关联]。

Spark节点的日志:

23 年 3 月 15 日 22:13:33 WARN ReliableDeliverySupervisor:与远程系统 [akka.tcp://wtb@127.0.0.1:2552] 的关联失败,地址现在被门控 [5000] 毫秒。原因是:[解除关联]。

我错过了什么导致这些错误?

4

1 回答 1

2

Spark 默认禁用 Akka 心跳。设置为 1000 秒。设置心跳间隔可以解决这个问题。

于 2015-03-24T16:47:06.237 回答