各位好：
我这边通过rest api 向jobmanager提交任务时，出现jobmaster
对应的actor创建过程被block住了，看源代码这块的逻辑也就只是注册个actor，（对akka内部逻辑不是很了解）。不知道各位大佬是否有碰到过类似问题（block
1个小时左右又自动正常了），对应block线程信息如下：
cluster-io-thread-14 BLOCKED blocked on java.lang.Object@67bb821e owned by
"cluster-io-thread-16" Id=218 at
org.apache.flink.runtime.rpc.akka.AkkaRpcService.registerAkkaRpcActor
(AkkaRpcService.java:308) at
org.apache.flink.runtime.rpc.akka.AkkaRpcService.startServer
(AkkaRpcService.java:227) at org.apache.flink.runtime.rpc.RpcEndpoint.
(RpcEndpoint.java:127) at org.apache.flink.runtime.rpc.FencedRpcEndpoint.
(FencedRpcEndpoint.java:48) at org.apache.flink.runtime.jobmaster.JobMaster.
(JobMaster.java:235) at
org.apache.flink.runtime.jobmaster.factories.DefaultJobMasterServiceFactory.createJobMasterService
(DefaultJobMasterServiceFactory.java:95) at
org.apache.flink.runtime.jobmaster.factories.DefaultJobMasterServiceFactory.createJobMasterService
(DefaultJobMasterServiceFactory.java:39) at
org.apache.flink.runtime.jobmaster.JobManagerRunnerImpl.
(JobManagerRunnerImpl.java:162) at
org.apache.flink.runtime.dispatcher.DefaultJobManagerRunnerFactory.createJobManagerRunner
(DefaultJobManagerRunnerFactory.java:86) at
org.apache.flink.runtime.dispatcher.Dispatcher.lambda$createJobManagerRunner$5
(Dispatcher.java:478) at
org.apache.flink.runtime.dispatcher.Dispatcher$$Lambda$796/1707020487.get
(flink-akka.actor.default-dispatcher-4684) at
java.util.concurrent.CompletableFuture$AsyncSupply.run
(CompletableFuture.java:1604) at
java.util.concurrent.ThreadPoolExecutor.runWorker
(ThreadPoolExecutor.java:1149) at
java.util.concurrent.ThreadPoolExecutor$Worker.run
(ThreadPoolExecutor.java:624) at java.lang.Thread.run
cluster-io-thread-16 WAITING waiting on
java.util.concurrent.CompletableFuture$Signaller@60dd3bae at
sun.misc.Unsafe.park (Native Method) at
java.util.concurrent.locks.LockSupport.park (LockSupport.java:175) at
java.util.concurrent.CompletableFuture$Signaller.block
(CompletableFuture.java:1707) at
java.util.concurrent.ForkJoinPool.managedBlock (ForkJoinPool.java:3323) at
java.util.concurrent.CompletableFuture.waitingGet
(CompletableFuture.java:1742) at java.util.concurrent.CompletableFuture.join
(CompletableFuture.java:1947) at
org.apache.flink.runtime.rpc.akka.SupervisorActor.startAkkaRpcActor
(SupervisorActor.java:208) at
org.apache.flink.runtime.rpc.akka.AkkaRpcService.registerAkkaRpcActor
(AkkaRpcService.java:311) at
org.apache.flink.runtime.rpc.akka.AkkaRpcService.startServer
(AkkaRpcService.java:227) at org.apache.flink.runtime.rpc.RpcEndpoint.
(RpcEndpoint.java:127) at org.apache.flink.runtime.rpc.FencedRpcEndpoint.
(FencedRpcEndpoint.java:48) at org.apache.flink.runtime.jobmaster.JobMaster.
(JobMaster.java:235) at
org.apache.flink.runtime.jobmaster.factories.DefaultJobMasterServiceFactory.createJobMasterService
(DefaultJobMasterServiceFactory.java:95) at
org.apache.flink.runtime.jobmaster.factories.DefaultJobMasterServiceFactory.createJobMasterService
(DefaultJobMasterServiceFactory.java:39) at
org.apache.flink.runtime.jobmaster.JobManagerRunnerImpl.
(JobManagerRunnerImpl.java:162) at
org.apache.flink.runtime.dispatcher.DefaultJobManagerRunnerFactory.createJobManagerRunner
(DefaultJobManagerRunnerFactory.java:86) at
org.apache.flink.runtime.dispatcher.Dispatcher.lambda$createJobManagerRunner$5
(Dispatcher.java:478) at
org.apache.flink.runtime.dispatcher.Dispatcher$$Lambda$796/1707020487.get
(flink-akka.actor.default-dispatcher-4684) at
java.util.concurrent.CompletableFuture$AsyncSupply.run
(CompletableFuture.java:1604) at
java.util.concurrent.ThreadPoolExecutor.runWorker
(ThreadPoolExecutor.java:1149) at
java.util.concurrent.ThreadPoolExecutor$Worker.run
(ThreadPoolExecutor.java:624) at java.lang.Thread.run
--
Sent from: http://apache-flink.147419.n8.nabble.com/
