首页 文章

从远程actor发送消息到Spark actorStream时,连接始终断开连接

提问于
浏览
0

当从远程演员发送消息到火花时,心跳将始终失败:

远程节点上的日志:

[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 回答

  • 2

    Spark默认禁用Akka心跳 . 它设置为1000秒 . 设置心跳间隔可以解决此问题 .

相关问题