Hi Team,
Any inputs please badly stuck.
Regards,Sunitha
On Sunday, May 22, 2022, 12:34:22 AM GMT+5:30, s_penakalap...@yahoo.com
<s_penakalap...@yahoo.com> wrote:
Hi All,
Help please!
We have standalone Flink service installed in individual VM and clubed to form
a cluster with HA and checkpoint in place. When cancelling Job, Flink cluster
went down and its unable to start up normally as Job manager is continuously
going down with the below error:
2022-05-21 14:33:09,314 ERROR
org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Fatal error
occurred in the cluster entrypoint.java.util.concurrent.CompletionException:
org.apache.flink.util.FlinkRuntimeException: Could not recover job with job id
3a97d1d50f663027ae81efe0f0aaaaaa.
Each attempt to restart cluster failed with the same error so the whole cluster
became unrecoverable and not operating, please help on the below points:1> In
which Fink/zookeeper folder job recovery details are stored and how can we
clear all old job instance so that Flink cluster will not try to recover and
start fresh to manually submit all job.
2> Since cluster is HA, we have 2 Job manager's even though one JM is going
down Flink is started but available slots are showing up as 0 (task manager's
are up but not displayed in web UI).
RegardsSunitha.
