[
https://issues.apache.org/jira/browse/FLINK-12205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hobo Chen closed FLINK-12205.
-----------------------------
Resolution: Not A Bug
> Internal server error., <Exception on server side:
> akka.pattern.AskTimeoutException: Ask timed out on
> [Actor[akka://flink/user/dispatcher#-1774235985]
> ------------------------------------------------------------------------------------------------------------------------------------------------------
>
> Key: FLINK-12205
> URL: https://issues.apache.org/jira/browse/FLINK-12205
> Project: Flink
> Issue Type: Bug
> Components: Examples
> Affects Versions: 1.8.0
> Environment: OSX
> flink-1.8.0-bin-scala_2.11
> Reporter: Hobo Chen
> Priority: Major
>
> I followed Local Step Tutorial to start flink.
> *env*
> OSX
> flink-1.8.0-bin-scala_2.11
>
> *start flink cluster result, it's ok.*
>
> {code:java}
> $ ./bin/start-cluster.sh
> $ tail log/flink-*-standalonesession-*.log
> 2019-04-15 23:46:14,335 INFO
> org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Rest endpoint
> listening at localhost:8081
> 2019-04-15 23:46:14,337 INFO
> org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint -
> http://localhost:8081 was granted leadership with
> leaderSessionID=00000000-0000-0000-0000-000000000000
> 2019-04-15 23:46:14,337 INFO
> org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Web frontend
> listening at http://localhost:8081.
> 2019-04-15 23:46:14,517 INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService
> - Starting RPC endpoint for
> org.apache.flink.runtime.resourcemanager.StandaloneResourceManager at
> akka://flink/user/resourcemanager .
> 2019-04-15 23:46:14,621 INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService
> - Starting RPC endpoint for
> org.apache.flink.runtime.dispatcher.StandaloneDispatcher at
> akka://flink/user/dispatcher .
> 2019-04-15 23:46:14,675 INFO
> org.apache.flink.runtime.resourcemanager.StandaloneResourceManager -
> ResourceManager akka.tcp://flink@localhost:6123/user/resourcemanager was
> granted leadership with fencing token 00000000000000000000000000000000
> 2019-04-15 23:46:14,676 INFO
> org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Starting
> the SlotManager.
> 2019-04-15 23:46:14,698 INFO
> org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Dispatcher
> akka.tcp://flink@localhost:6123/user/dispatcher was granted leadership with
> fencing token 00000000-0000-0000-0000-000000000000
> 2019-04-15 23:46:14,701 INFO
> org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Recovering all
> persisted jobs.
> 2019-04-15 23:46:15,559 INFO
> org.apache.flink.runtime.resourcemanager.StandaloneResourceManager -
> Registering TaskManager with ResourceID 6e31e97e88429e4eb8a55489e7334560
> (akka.tcp://flink@192.168.1.5:65505/user/taskmanager_0) at ResourceManager
> {code}
>
>
> *When I run the example, have error.*
> {code:java}
> $ ./bin/flink run examples/streaming/SocketWindowWordCount.jar --port
> 9000{code}
> *client error log*
> {code:java}
> 2019-04-15 23:53:11,171 ERROR org.apache.flink.client.cli.CliFrontend - Error
> while running the command.
> org.apache.flink.client.program.ProgramInvocationException: Could not
> retrieve the execution result. (JobID: 42cf26445edd68aef39b67a543cca421)
> 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.streaming.api.environment.StreamContextEnvironment.execute(StreamContextEnvironment.java:66)
> at
> org.apache.flink.streaming.examples.socket.SocketWindowWordCount.main(SocketWindowWordCount.java:92)
> 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:529)
> 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.client.cli.CliFrontend$$Lambda$5/1160003871.call(Unknown
> Source)
> at
> org.apache.flink.runtime.security.NoOpSecurityContext.runSecured(NoOpSecurityContext.java:30)
> at org.apache.flink.client.cli.CliFrontend.main(CliFrontend.java:1126)
> 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
> org.apache.flink.client.program.rest.RestClusterClient$$Lambda$17/1740223770.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$5(FutureUtils.java:207)
> at
> org.apache.flink.runtime.concurrent.FutureUtils$$Lambda$36/1819496669.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#-1774235985]] 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: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$35/254601087.apply(Unknown
> Source)
> at
> java.util.concurrent.CompletableFuture$AsyncCompose.exec(CompletableFuture.java:604)
> ... 4 more{code}
> *standalonesession error log*
> {code:java}
> 2019-04-15 23:54:11,423 ERROR
> org.apache.flink.runtime.rest.handler.job.JobsOverviewHandler - Unhandled
> exception.
> akka.pattern.AskTimeoutException: Ask timed out on
> [Actor[akka://flink/user/dispatcher#-1774235985]] 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:745)
> 2019-04-15 23:54:11,432 ERROR
> org.apache.flink.runtime.rest.handler.cluster.ClusterOverviewHandler -
> Unhandled exception.
> akka.pattern.AskTimeoutException: Ask timed out on
> [Actor[akka://flink/user/dispatcher#-1774235985]] 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:745)
> ……
> {code}
> and the standalonesession error never stop
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
