Hi, Shubham Which Flink version are you using? AFAIK, the JobManager will recover the job from the HA store first, and it won't submit the same job (identify be jobID) again if it has already been recovered.
Best, Weihua On Tue, May 2, 2023 at 8:02 PM Shubham Bansal <s.bansa...@gmail.com> wrote: > Hello everyone, > > Elastic scaling, as of now, has to be started in application mode. I am > having some trouble in making it work with HA. > I have a jobmanager pod and a single taskmanager pod, I use a post install > helm hook to start the jobmanager along with the single job (As it's > required in application mode). > >> ./bin/standalone-job.sh start (..removed for brevity) >> >> If due to some reason my job manager goes down, I have two options > > 1. I start the same job from the required checkpoint, my HA > (zookeeper) also kicks in and submits another job to the jobmanager. So > there are 2 jobs running where it should have been 1. > 2. If I don't submit the job, I don't have any other way to start the > jobmanager without the job with elastic scaling enabled. > > Is there any way to start the jobmanager without the job with elastic > scaling? > > Best, > Shubham >
