感谢大神,
是我配置的资源太少导致响应慢,导致akka 超时。
现在我换了一个k8s 集群,调大了资源,已经不再配到邮件中的发生的异常。
原始邮件
发件人:"Zili Chen"< wander4...@gmail.com ;
发件时间:2019/8/7 15:32
收件人:"王智"< ben.wa...@foxmail.com ;
抄送人:"user-zh"< user-zh@flink.apache.org ;
主题:Re: Re: submit jobGraph e
,gateway 通过jobmanager
> 对应的jobmanager-service
> 找到jobmanager对应的服务。猜测是因为我在服务中仅定义了上述4个端口,所以gateway节点上的进程无法通过jobmanager-service
> 与jobmanager 通讯。
>
>
> 附: 以下是我的验证方案: 将提交节点与jobmanager 放入同一个pod,使用回环地址(不会有端口限制)通讯,可以成功提交job【flink
> 的配置和代码完全一致】
>
>
>
>
>
>
>
>
;user-zh"< user-zh@flink.apache.org ;
主题:Re: submit jobGraph error on server side
问题是 Ask timed out on [Actor[akka://flink/user/dispatcher#-273192824]] after
[1 ms]. Sender[null] sent message of type "org.apache.flink.runtime.rpc.
messages.LocalFencedMessage".
也就是 submit job 的时候在请求 Di
问题是 Ask timed out on [Actor[akka://flink/user/dispatcher#-273192824]] after
[1 ms]. Sender[null] sent message of type "org.apache.flink.runtime.rpc.
messages.LocalFencedMessage".
也就是 submit job 的时候在请求 Dispatcher 的时候 akka ask timeout
了,可以检查一下配置的地址和端口是否正确,或者贴出你的相关配置。
Best,
tison.
王智