flink 1.12 通过rest api 提交任务时 SupervisorActor block

2021-05-27 Thread seuzxc
各位好: 我这边flink 1.12运行一段时间后出现通过rest api提交任务 进行jobMaster 对应actor创建时被block,请问这种情况一般是什么原因呢?线程block信息如下(看源码这个位置只是向SupervisorActor发送消息注册一个jobmaster对应的actor,理论上不会有什么消耗资源的,但是我这线上环境有时会block一个小时然后恢复正常) cluster-io-thread-14BLOCKED blocked on java.lang.Object@67bb821e owned by "cluster-io-thread-16" I

flink 1.12 通过rest api 提交任务时 SupervisorActor block

2021-05-27 Thread seuzxc
各位好: 我这边通过rest api 向jobmanager提交任务时,出现jobmaster 对应的actor创建过程被block住了,看源代码这块的逻辑也就只是注册个actor,(对akka内部逻辑不是很了解)。不知道各位大佬是否有碰到过类似问题(block 1个小时左右又自动正常了),对应block线程信息如下:cluster-io-thread-14BLOCKED blocked on java.lang.Object@67bb821e owned by "cluster-io-thread-16" Id=218at org.apache.flink.runt

flink 1.12 通过rest api 提交任务时 SupervisorActor block

2021-05-27 Thread seuzxc
各位好: 我这边通过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.r