回复:Re: Re: submit jobGraph error on server side

2019-08-08 文章 王智
感谢大神, 是我配置的资源太少导致响应慢,导致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

Re: Re: submit jobGraph error on server side

2019-08-07 文章 Zili Chen
,gateway 通过jobmanager > 对应的jobmanager-service > 找到jobmanager对应的服务。猜测是因为我在服务中仅定义了上述4个端口,所以gateway节点上的进程无法通过jobmanager-service > 与jobmanager 通讯。 > > > 附: 以下是我的验证方案: 将提交节点与jobmanager 放入同一个pod,使用回环地址(不会有端口限制)通讯,可以成功提交job【flink > 的配置和代码完全一致】 > > > > > > > >

回复:Re: submit jobGraph error on server side

2019-08-07 文章 王智
;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

Re: submit jobGraph error on server side

2019-08-06 文章 Zili Chen
问题是 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. 王智