[
https://issues.apache.org/jira/browse/FLINK-12205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16818240#comment-16818240
]
Ken Krugler commented on FLINK-12205:
-------------------------------------
Hi [~hbchen] - I didn't see this posted on the user mailing list. If that's the
case, please close this issue, then post to the list, and based on feedback
from the Flink community, it will hopefully become clear whether the issue is
one of user setup/configuration, or a real bug in Flink - thanks!
A quick search of Jira also showed
https://issues.apache.org/jira/browse/FLINK-11738, which seems similar, though
the referenced issue was fixed in 1.8, which you're using.
> 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)
