Hi, Thanks for your reply. It is slightly different, would be happy to have any suggestion for the scenario you mentioned. My scenario: I have 2 namespaces say ns1,ns2. I have to make sure only one of ns1 or ns2 should run my flink jobs. Say initially ns1 is running flink jobs, later planned to move them to ns2. Now when I start in ns2, I can make an api call to ns1 jobmanager about running jobs and if no jobs then only I should start in ns2. I can introduce this logic inside the flink job java main method where my total streaming logic present. So if I identify then, how can I stop the initiated job?
Thanks, Nagasudhakar. On Thu, 13 Apr, 2023, 7:08 am Shammon FY, <zjur...@gmail.com> wrote: > Hi naga > > Could you provide a specific description of your scene? It sounds like > your requirement requires a uniqueness check to ensure that there are no > multiple identical jobs running simultaneously, right? > > Best, > Shammon FY > > On Wed, Apr 12, 2023 at 4:08 PM naga sudhakar <nagasudha...@gmail.com> > wrote: > >> Thanks for your email. >> I am looking more in terms of running these flinkk jobs in multi names >> pace environment and make sure only one namespace flink jobs are running. >> So on the Job manager when i try to start a flink job, it has to check if >> it's allowed to run in this namespace or not and accordingly flink job >> shud turn into running state otherwise it shud cancel by itself >> >> >> >> On Wed, 12 Apr, 2023, 12:06 pm Gen Luo, <luogen...@gmail.com> wrote: >> >>> Hi, >>> >>> Is the job you want to start running or already finished? >>> If the job is running, this is simply a failover or a JM failover case. >>> While if the job has finished, there's no such feature that can restart >>> the job >>> automatically, AFAIK. The job has to be submitted again. >>> >>> On Wed, Apr 12, 2023 at 10:58 AM naga sudhakar <nagasudha...@gmail.com> >>> wrote: >>> >>>> Hi Team, >>>> Greetings!! >>>> Just wanted to know when job manager or task manager is being >>>> restarted, is there a way to run the existing flink jobs based on a >>>> condition? Same query when I am starting flink job fresh also. >>>> >>>> Please let me know if any more information is required from my side. >>>> >>>> Thanks & Regards >>>> Nagasudhakar Sajja. >>>> >>>
