当从远程演员发送消息到火花时,心跳将始终失败:
远程节点上的日志:
[INFO] [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]没有来自远程的响应 . 握手超时或运输故障检测器触发 .
[WARN] [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] ms门控 . 原因是:[Disocociated] .
登录Spark节点:
15/03/23 22:13:33 WARN ReliableDeliverySupervisor:与远程系统的关联[akka.tcp://wtb@127.0.0.1:2552]失败,地址现在为[5000] ms门控 . 原因是:[Disocociated] .
我错过了什么造成了这些错误?
1 回答
Spark默认禁用Akka心跳 . 它设置为1000秒 . 设置心跳间隔可以解决此问题 .