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

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

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"

Re: flink Application Native k8s使用oss作为backend日志偶尔报错

2021-03-08 Thread seuzxc
请问您这个问题解决了吗,我的也有这个错误信息 -- Sent from: http://apache-flink.147419.n8.nabble.com/

Re: Flink RocksDBStateBackend 可以设置阿里云 OSS 存储吗?

2021-03-08 Thread seuzxc
我用oss设置,状态信息能写入,但是oss日志总是提示如下的信息,有遇到过吗? 2021-03-08 20:18:58.512 [INFO][cluster-io-thread-2]: o.a.f.f.o.s.c.a.o.c.u.LogUtils 66 logException - [Server]Unable to execute HTTP request: Not Found [ErrorCode]: NoSuchKey [RequestId]: 604616328586350B9C61 [HostId]: null -- Sent from:

Re: JobGraphs not cleaned up in HA mode

2019-11-27 Thread seuzxc
hi ,I've the same problem with flink 1.9.1 , any solution to fix it when the k8s redoploy jobmanager , the error looks like (seems zk not remove submitted job info, but jobmanager remove the file): Caused by: org.apache.flink.util.FlinkException: Could not retrieve submitted JobGraph from