JobManager doesn't bring up new TaskManager during failure recovery

2022-04-21 Thread Zheng, Chenyu
Hi developers! I got a strange bug during failure recovery of Flink. It seems the JobManager doesn't bring up new TaskManager during failure recovery. Some logs and information of the Flink job are pasted below. Can you take a look and give me some guidance? Thank you so much! Flink version: 1

Re: JobManager doesn't bring up new TaskManager during failure recovery

2022-04-22 Thread Zheng, Chenyu
would JobManager create new TaskManager in that case? BRs, Chenyu From: Yang Wang Date: Friday, April 22, 2022 at 4:49 PM To: "Zheng, Chenyu" Cc: "user@flink.apache.org" , "user...@flink.apache.org" Subject: Re: JobManager doesn't bring up new TaskManager dur

Re: JobManager doesn't bring up new TaskManager during failure recovery

2022-04-22 Thread Zheng, Chenyu
I created a JIRA ticket https://issues.apache.org/jira/browse/FLINK-27350 to track this issue. BRs, Chenyu From: "Zheng, Chenyu" Date: Friday, April 22, 2022 at 6:26 PM To: Yang Wang Cc: "user@flink.apache.org" , "user...@flink.apache.org" Subject: Re: J

Re: JobManager doesn't bring up new TaskManager during failure recovery

2022-04-23 Thread Zheng, Chenyu
Thank you so much, Yang! It looks very likely that this issue is causing the bug I met. I’ll upgrade my Flink version and test if I can reproduce that bug. BRs, Chenyu From: Yang Wang Date: Sunday, April 24, 2022 at 10:20 AM To: "Zheng, Chenyu" Cc: "user@flink.apac