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 ve

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

2022-04-22 Thread Yang Wang
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! > > > > Fli

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
y, in our expectation, 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'

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

2022-04-23 Thread Yang Wang
k 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: JobManager d

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

2022-04-23 Thread Zheng, Chenyu
he.org" , "user...@flink.apache.org" Subject: Re: JobManager doesn't bring up new TaskManager during failure recovery After more debugging, I think this issue is same as FLINK-24315[1], which is fixed in 1.13.3. [1]. https://issues.apache.org/jira/browse/FLINK-24315<https://nam12