感谢大神,
是我配置的资源太少导致响应慢,导致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: submi
> 原始邮件
>
> 发件人:"Zili Chen"< wander4...@gmail.com >;
>
> 发件时间:2019/8/6 19:19
>
> 收件人:"user-zh"< user-zh@flink.apache.org >;
>
> 主题:Re: submit jobGraph error on server side
>
>
> 问题是 Ask timed out on [Actor[akka://flink/user/dispatcher
uot;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 的
问题是 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.
王智 于2019年8月
向session cluster 提交job 出错,麻烦各位老师帮忙看下,给点排查提示 THX~
环境:
blink 1.8.0
用docker 方式启动的flink session cluster,flink 集群独立,我从集群外的一个docker
节点提交job(该节点的flink-conf.yaml 配置与flink 集群内的配置一致)
--
报错信息:
The program finished