RE: org.apache.flink.runtime.client.JobSubmissionException: Job has already been submitted

2021-01-22 Thread Hailu, Andreas [Engineering]
ursday, January 21, 2021 10:00 AM To: Hailu, Andreas [Engineering] mailto:andreas.ha...@ny.email.gs.com>> Cc: user@flink.apache.org<mailto:user@flink.apache.org> Subject: Re: org.apache.flink.runtime.client.JobSubmissionException: Job has already been submitted Thanks a lot for y

Re: org.apache.flink.runtime.client.JobSubmissionException: Job has already been submitted

2021-01-21 Thread Robert Metzger
*From:* Robert Metzger > *Sent:* Thursday, January 21, 2021 10:00 AM > *To:* Hailu, Andreas [Engineering] > *Cc:* user@flink.apache.org > *Subject:* Re: org.apache.flink.runtime.client.JobSubmissionException: > Job has already been submitted > > > > Thanks a lot fo

RE: org.apache.flink.runtime.client.JobSubmissionException: Job has already been submitted

2021-01-21 Thread Hailu, Andreas [Engineering]
this application. Is it possible that it’s busy processing other jobs? // ah From: Robert Metzger Sent: Thursday, January 21, 2021 10:00 AM To: Hailu, Andreas [Engineering] Cc: user@flink.apache.org Subject: Re: org.apache.flink.runtime.client.JobSubmissionException: Job has already been

Re: org.apache.flink.runtime.client.JobSubmissionException: Job has already been submitted

2021-01-21 Thread Robert Metzger
(CompletableFuture.java:561) > >at > java.util.concurrent.CompletableFuture$UniCompose.tryFire(CompletableFuture.java:929) > >at > java.util.concurrent.CompletableFuture$Completion.run(CompletableFuture.java:442) > >... 3 more > > Ca

org.apache.flink.runtime.client.JobSubmissionException: Job has already been submitted

2021-01-20 Thread Hailu, Andreas [Engineering]
Hello, We're running 1.9.2 on YARN, and are seeing some interesting behavior when submitting jobs in a multi-threaded fashion to an application's Flink cluster. The error we see reported in the client application logs is the following: org.apache.flink.client.program.ProgramInvocationException: