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
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
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
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