各位好： 我这边通过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=218at 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.runcluster-io-thread-16 WAITING waiting on java.util.concurrent.CompletableFuture$Signaller@60dd3baeat 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/
