flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jeff kit <bbm...@gmail.com>
Subject Re: Mac操作系统下Ask timed out问題
Date Tue, 05 Nov 2019 06:43:12 GMT
你好。
我本地的Flink是官网提供的Binary包,非自己编译的。
我相信我的情况是少数,绝大多数人的Mac都是能跑的。

On Tue, Nov 5, 2019 at 2:24 PM Biao Liu <mmyy1110@gmail.com> wrote:

> 你好,
>
> MacOS 可以跑 Flink,我自己刚试了下,复制你的命令就可以跑。
> 建议再查一下你本地的环境,你本地的 Flink 是自己编译的吗?如果不行试一下
Flink 提供的 binary 包 [1]?
>
> [1] https://flink.apache.org/downloads.html
>
> Thanks,
> Biao /'bɪ.aʊ/
>
>
>
> On Tue, 5 Nov 2019 at 12:30, jeff kit <bbmyth@gmail.com> wrote:
>
> > HI,大家好:
> > 我在运行Flink官方的Quick
> > Start就遇到了问題。为了避免自己问蠢问題,我先做了很多尝试,如换Flink的版本,从1.7到1.8及至1.9都试过,在我自己的Mac
OS
> > X上这个问題是必然出现的,而换到其他操作系统例如Windows,则是正常的。
> >
> > 这也许不是一个常见的问題,更多是我本机的运行环境问題,但多天尝试下来仍然没有找到解决方法,才在这里求助一下。
> >
> > 操作步骤:
> > 1. ./bin/start-cluster.sh  # 启动flink。
> > 2. ./bin/flink run examples/batch/WordCount.jar   # 提交wordCount 包
> >
> > 随后就是抛了异常:
> > Starting execution of program
> > Executing WordCount example with default input data set.
> > Use --input to specify file input.
> > Printing result to stdout. Use --output to specify output path.
> >
> > ------------------------------------------------------------
> >  The program finished with the following exception:
> >
> > org.apache.flink.client.program.ProgramInvocationException: Could not
> > retrieve the execution result. (JobID: 81bc8720dee57710788cc8e41079ba4d)
> > at
> >
> >
> org.apache.flink.client.program.rest.RestClusterClient.submitJob(RestClusterClient.java:255)
> > at
> > org.apache.flink.client.program.ClusterClient.run(ClusterClient.java:338)
> > at
> > org.apache.flink.client.program.ClusterClient.run(ClusterClient.java:326)
> > at
> >
> >
> org.apache.flink.client.program.ContextEnvironment.execute(ContextEnvironment.java:62)
> > at
> >
> >
> org.apache.flink.api.java.ExecutionEnvironment.execute(ExecutionEnvironment.java:820)
> > at org.apache.flink.api.java.DataSet.collect(DataSet.java:413)
> > at org.apache.flink.api.java.DataSet.print(DataSet.java:1652)
> > at
> >
> org.apache.flink.examples.java.wordcount.WordCount.main(WordCount.java:88)
> > 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:483)
> > at
> >
> >
> org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:576)
> > at
> >
> >
> org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:438)
> > at
> > org.apache.flink.client.program.ClusterClient.run(ClusterClient.java:274)
> > at
> >
> >
> org.apache.flink.client.cli.CliFrontend.executeProgram(CliFrontend.java:746)
> > at
> org.apache.flink.client.cli.CliFrontend.runProgram(CliFrontend.java:273)
> > at org.apache.flink.client.cli.CliFrontend.run(CliFrontend.java:205)
> > at
> >
> >
> org.apache.flink.client.cli.CliFrontend.parseParameters(CliFrontend.java:1010)
> > at
> >
> >
> org.apache.flink.client.cli.CliFrontend.lambda$main$10(CliFrontend.java:1083)
> > at
> >
> org.apache.flink.client.cli.CliFrontend$$Lambda$31/1990451863.call(Unknown
> > Source)
> > at
> >
> >
> org.apache.flink.runtime.security.NoOpSecurityContext.runSecured(NoOpSecurityContext.java:30)
> > at org.apache.flink.client.cli.CliFrontend.main(CliFrontend.java:1083)
> > 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:382)
> > at
> >
> >
> org.apache.flink.client.program.rest.RestClusterClient$$Lambda$44/1067599825.apply(Unknown
> > Source)
> > at
> >
> >
> java.util.concurrent.CompletableFuture$ExceptionCompletion.run(CompletableFuture.java:1246)
> > at
> >
> >
> java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:193)
> > at
> >
> >
> java.util.concurrent.CompletableFuture.internalComplete(CompletableFuture.java:210)
> > at
> >
> >
> java.util.concurrent.CompletableFuture$ThenApply.run(CompletableFuture.java:723)
> > at
> >
> >
> java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:193)
> > at
> >
> >
> java.util.concurrent.CompletableFuture.internalComplete(CompletableFuture.java:210)
> > at
> >
> >
> java.util.concurrent.CompletableFuture$ThenCopy.run(CompletableFuture.java:1333)
> > at
> >
> >
> java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:193)
> > at
> >
> >
> java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:2361)
> > at
> >
> >
> org.apache.flink.runtime.concurrent.FutureUtils.lambda$retryOperationWithDelay$8(FutureUtils.java:263)
> > at
> >
> >
> org.apache.flink.runtime.concurrent.FutureUtils$$Lambda$63/318445555.accept(Unknown
> > Source)
> > at
> >
> >
> java.util.concurrent.CompletableFuture$WhenCompleteCompletion.run(CompletableFuture.java:1298)
> > at
> >
> >
> java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:193)
> > at
> >
> >
> java.util.concurrent.CompletableFuture.internalComplete(CompletableFuture.java:210)
> > at
> >
> >
> java.util.concurrent.CompletableFuture$AsyncCompose.exec(CompletableFuture.java:626)
> > at
> >
> >
> java.util.concurrent.CompletableFuture$Async.run(CompletableFuture.java:428)
> > at
> >
> >
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
> > at
> >
> >
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
> > at java.lang.Thread.run(Thread.java:745)
> > Caused by: org.apache.flink.runtime.rest.util.RestClientException:
> > [Internal server error., <Exception on server side:
> > akka.pattern.AskTimeoutException: Ask timed out on
> > [Actor[akka://flink/user/dispatcher#-80166821]] after [10000 ms]. Message
> > of type [org.apache.flink.runtime.rpc.messages.LocalFencedMessage]. A
> > typical reason for `AskTimeoutException` is that the recipient actor
> didn't
> > send a reply.
> > at
> >
> >
> akka.pattern.PromiseActorRef$.$anonfun$defaultOnTimeout$1(AskSupport.scala:635)
> > at akka.pattern.PromiseActorRef$$$Lambda$190/1064265473.apply(Unknown
> > Source)
> > at akka.pattern.PromiseActorRef$.$anonfun$apply$1(AskSupport.scala:650)
> > at
> akka.pattern.PromiseActorRef$$$Lambda$191/517355658.apply$mcV$sp(Unknown
> > Source)
> > at akka.actor.Scheduler$$anon$4.run(Scheduler.scala:205)
> > at
> >
> >
> scala.concurrent.Future$InternalCallbackExecutor$.unbatchedExecute(Future.scala:870)
> > at scala.concurrent.BatchingExecutor.execute(BatchingExecutor.scala:109)
> > at scala.concurrent.BatchingExecutor.execute$(BatchingExecutor.scala:103)
> > at
> >
> scala.concurrent.Future$InternalCallbackExecutor$.execute(Future.scala:868)
> > at
> >
> >
> akka.actor.LightArrayRevolverScheduler$TaskHolder.executeTask(LightArrayRevolverScheduler.scala:328)
> > at
> >
> >
> akka.actor.LightArrayRevolverScheduler$$anon$3.executeBucket$1(LightArrayRevolverScheduler.scala:279)
> > at
> >
> >
> akka.actor.LightArrayRevolverScheduler$$anon$3.nextTick(LightArrayRevolverScheduler.scala:283)
> > at
> >
> >
> akka.actor.LightArrayRevolverScheduler$$anon$3.run(LightArrayRevolverScheduler.scala:235)
> > at java.lang.Thread.run(Thread.java:745)
> >
> > 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
> >
> >
> org.apache.flink.runtime.rest.RestClient$$Lambda$62/2010911005.apply(Unknown
> > Source)
> > at
> >
> >
> java.util.concurrent.CompletableFuture$AsyncCompose.exec(CompletableFuture.java:604)
> > ... 4 more
> >
> >
> >
> >
> 对了,在我的Mac上,遇到的奇怪问題还不止这一个,在其他人的机器上正常运行的Flink程序,到我这里都是有这样那样的问題的。所以,Flink对系统环境有什么依赖吗?
> > 我本地的环境是 jdk 1.8.0, maven 3.5.4
> >
> > 谢谢大家。
> >
>

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