flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Zili Chen <wander4...@gmail.com>
Subject Re: Re: submit jobGraph error on server side
Date Wed, 07 Aug 2019 07:32:07 GMT
从错误堆栈上看你的请求应该是已经发到 jobmanager 上了,也就是不存在找不到端口的问题。
但是 jobmanager 在处理 submit job 的时候某个动作超时了。你这个问题是一旦把
gateway 分开就稳定复现吗?也有可能是 akka 偶然的超时。

Best,
tison.


王智 <ben.wangz@foxmail.com> 于2019年8月7日周三 下午2:33写道:

> 感谢您的回复与指导~
>
>
> 经过简单的验证(验证方案在邮件末尾),明确是网络问题。
>
>
> 现在我猜测是flink run 提交job graph 的时候打开了除 这四个以外的端口导致。麻烦再请教一下,flink
jobmanager
> 是否会打开新的端口进行通讯(或者还有其他端口配置我没有注意到)
>
> ports:
>   - containerPort: 6123
>     protocol: TCP
>   - containerPort: 6124
>     protocol: TCP
>   - containerPort: 6125
>     protocol: TCP
>   - containerPort: 8081
>     protocol: TCP
>
>
> # flink conf 内的配置
>
> jobmanager.rpc.port: 6123
>
> jobmanager.rpc.port: 6123
>
> jobmanager.rpc.port: 6123
>
> blob.server.port: 6124
>
> query.server.port: 6125
>
> # 8081 没有配置,使用默认,web ui 可以正常访问
>
> 我使用k8s 搭建的环境,提交任务的节点(命名为gateway)与jobmanager
在两个不同的pod,gateway 通过jobmanager
> 对应的jobmanager-service
> 找到jobmanager对应的服务。猜测是因为我在服务中仅定义了上述4个端口,所以gateway节点上的进程无法通过jobmanager-service
> 与jobmanager 通讯。
>
>
> 附: 以下是我的验证方案: 将提交节点与jobmanager 放入同一个pod,使用回环地址(不会有端口限制)通讯,可以成功提交job【flink
的配置和代码完全一致】
>
>
>
>
>
>
>
>
> 原始邮件
>
> 发件人:"Zili Chen"< wander4096@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#-273192824]] after
> [10000 ms]. Sender[null] sent message of type
> "org.apache.flink.runtime.rpc.
> messages.LocalFencedMessage".
>
> 也就是 submit job 的时候在请求 Dispatcher 的时候 akka ask timeout
> 了,可以检查一下配置的地址和端口是否正确,或者贴出你的相关配置。
>
> Best,
> tison.
>
>
> 王智于2019年8月6日周二 下午7:13写道:
>
> > 向session cluster 提交job 出错,麻烦各位老师帮忙看下,给点排查提示
THX~
> >
> >
> >
> >
> > 环境:
> >
> > blink 1.8.0
> >
> > 用docker 方式启动的flink session cluster,flink 集群独立,我从集群外的一个docker
> > 节点提交job(该节点的flink-conf.yaml 配置与flink 集群内的配置一致)
> >
> >
> >
> >
> > ----------------------
> >
> >
> > 报错信息:
> >
> > ------------------------------------------------------------
> >
> >  The program finished with the following exception:
> >
> >
> >
> >
> > org.apache.flink.client.program.ProgramInvocationException: The main
> > method caused an error:
> > org.apache.flink.client.program.ProgramInvocationException: Could not
> > retrieve the execution result. (JobID: 82
> >
> > 3a336683f6476b3e7ee2780c33395b)
> >
> >         at
> >
> org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:546)
> >
> >         at
> >
> org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:421)
> >
> >         at
> > org.apache.flink.client.program.ClusterClient.run(ClusterClient.java:423)
> >
> >         at
> >
> org.apache.flink.client.cli.CliFrontend.executeProgram(CliFrontend.java:813)
> >
> >         at
> > org.apache.flink.client.cli.CliFrontend.runProgram(CliFrontend.java:287)
> >
> >         at
> > org.apache.flink.client.cli.CliFrontend.run(CliFrontend.java:213)
> >
> >         at
> >
> org.apache.flink.client.cli.CliFrontend.parseParameters(CliFrontend.java:1050)
> >
> >         at
> >
> org.apache.flink.client.cli.CliFrontend.lambda$main$11(CliFrontend.java:1126)
> >
> >         at
> >
> org.apache.flink.runtime.security.NoOpSecurityContext.runSecured(NoOpSecurityContext.java:30)
> >
> >         at
> > org.apache.flink.client.cli.CliFrontend.main(CliFrontend.java:1126)
> >
> > Caused by: java.lang.RuntimeException:
> > org.apache.flink.client.program.ProgramInvocationException: Could not
> > retrieve the execution result. (JobID: 823a336683f6476b3e7ee2780c33395b)
> >
> >         at
> >
> com.xxxxxx.data.platform.pandora.flink.table.BatchSqlRunner.run(BatchSqlRunner.java:176)
> >
> >         at
> >
> com.xxxxxx.data.platform.pandora.flink.EntryPoint.main(EntryPoint.java:78)
> >
> >         at
> > sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> >
> >         at
> >
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> >
> >         at
> >
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> >
> >         at
> > java.lang.reflect.Method.invoke(Method.java:498)
> >
> >         at
> >
> org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:529)
> >
> >         ... 9 more
> >
> > Caused by: org.apache.flink.client.program.ProgramInvocationException:
> > Could not retrieve the execution result. (JobID:
> > 823a336683f6476b3e7ee2780c33395b)
> >
> >         at
> >
> org.apache.flink.client.program.rest.RestClusterClient.submitJob(RestClusterClient.java:261)
> >
> >         at
> > org.apache.flink.client.program.ClusterClient.run(ClusterClient.java:483)
> >
> >         at
> > org.apache.flink.client.program.ClusterClient.run(ClusterClient.java:471)
> >
> >         at
> >
> org.apache.flink.client.program.ContextEnvironment.execute(ContextEnvironment.java:62)
> >
> >         at
> >
> com.xxxxxx.data.platform.pandora.flink.table.BatchSqlRunner.run(BatchSqlRunner.java:174)
> >
> >         ... 15 more
> >
> >
> >
> > Caused by: org.apache.flink.runtime.client.JobSubmissionException: Failed
> > to submit JobGraph.
> >
> >         at
> >
> org.apache.flink.client.program.rest.RestClusterClient.lambda$submitJob$8(RestClusterClient.java:388)
> >
> >         at
> >
> java.util.concurrent.CompletableFuture.uniExceptionally(CompletableFuture.java:870)
> >
> >         at
> >
> java.util.concurrent.CompletableFuture$UniExceptionally.tryFire(CompletableFuture.java:852)
> >
> >         at
> >
> java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474)
> >
> >         at
> >
> java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1977)
> >
> >         at
> >
> org.apache.flink.runtime.concurrent.FutureUtils.lambda$retryOperationWithDelay$5(FutureUtils.java:207)
> >
> >         at
> >
> java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:760)
> >
> >         at
> >
> java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:736)
> >
> >         at
> >
> java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474)
> >
> >         at
> >
> java.util.concurrent.CompletableFuture.postFire(CompletableFuture.java:561)
> >
> >         at
> >
> java.util.concurrent.CompletableFuture$UniCompose.tryFire(CompletableFuture.java:929)
> >
> >         at
> >
> java.util.concurrent.CompletableFuture$Completion.run(CompletableFuture.java:442)
> >
> >         at
> >
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
> >
> >         at
> >
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> >
> >         at java.lang.Thread.run(Thread.java:748)
> >
> > Caused by: org.apache.flink.runtime.rest.util.RestClientException:
> > [Internal server error.,>
> > akka.pattern.AskTimeoutException: Ask timed out on
> > [Actor[akka://flink/user/dispatcher#-273192824]] after [10000 ms].
> > Sender[null] sent message of type
> > "org.apache.flink.runtime.rpc.messages.LocalFencedMessage".
> >
> >         at
> >
> akka.pattern.PromiseActorRef$$anonfun$1.apply$mcV$sp(AskSupport.scala:604)
> >
> >         at
> > akka.actor.Scheduler$$anon$4.run(Scheduler.scala:126)
> >
> >         at
> >
> scala.concurrent.Future$InternalCallbackExecutor$.unbatchedExecute(Future.scala:601)
> >
> >         at
> >
> scala.concurrent.BatchingExecutor$class.execute(BatchingExecutor.scala:109)
> >
> >         at
> >
> scala.concurrent.Future$InternalCallbackExecutor$.execute(Future.scala:599)
> >
> >         at
> >
> akka.actor.LightArrayRevolverScheduler$TaskHolder.executeTask(LightArrayRevolverScheduler.scala:329)
> >
> >         at
> >
> akka.actor.LightArrayRevolverScheduler$$anon$4.executeBucket$1(LightArrayRevolverScheduler.scala:280)
> >
> >         at
> >
> akka.actor.LightArrayRevolverScheduler$$anon$4.nextTick(LightArrayRevolverScheduler.scala:284)
> >
> >         at
> >
> akka.actor.LightArrayRevolverScheduler$$anon$4.run(LightArrayRevolverScheduler.scala:236)
> >
> >         at java.lang.Thread.run(Thread.java:748)
> >
> >
> >
> >
> > End of exception on server side>]
> >
> >         at
> >
> org.apache.flink.runtime.rest.RestClient.parseResponse(RestClient.java:389)
> >
> >         at
> >
> org.apache.flink.runtime.rest.RestClient.lambda$submitRequest$3(RestClient.java:373)
> >
> >         at
> >
> java.util.concurrent.CompletableFuture.uniCompose(CompletableFuture.java:952)
> >
> >         at
> >
> java.util.concurrent.CompletableFuture$UniCompose.tryFire(CompletableFuture.java:926)
> >
> >         ... 4 more
>
>

Mime
  • Unnamed multipart/related (inline, None, 0 bytes)
View raw message