You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by Mohsen Rezaei <mo...@gmail.com> on 2023/02/08 17:21:54 UTC
Fwd: [FLINK-30596] Duplicate jobs on /run with the same jobId
Hi,
I was hoping to resurface this issue given that it affects any application
using the REST endpoints to run/submit jobs, causing confusion on the
actual state of the submitted jobs in a cluster.
I've created a PR against the "master" branch, and I'd like to be able to
port it back to 1.16.2 and 1.15.4 to close the loop on the issue for the
last three major releases:
https://github.com/apache/flink/pull/21849
Cheers,
Mohsen Rezaei
---------- Forwarded message ---------
From: Mohsen Rezaei <mo...@gmail.com>
Date: Sat, Jan 21, 2023 at 5:58 PM
Subject: Duplicate jobs on /run with the same jobId
To: <de...@flink.apache.org>
Hi everyone,
I have run into an issue with the Dispatcher's runJob() that accepts
multiple jobs and starts them with the same jobId.
The filtering fix in waitForTerminatingJob [1] fixes the issue, but I need
a consensus from devs to ensure this is the proper fix, before submitting a
PR.
Cheers,
Mohsen Rezaei
[1] https://issues.apache.org/jira/browse/FLINK-30596
Re: Fwd: [FLINK-30596] Duplicate jobs on /run with the same jobId
Posted by Chesnay Schepler <ch...@apache.org>.
FYI, the original mail never actually made it to the dev mailing list
(maybe got stuck in moderation queue).
On 08/02/2023 18:21, Mohsen Rezaei wrote:
> Hi,
>
> I was hoping to resurface this issue given that it affects any application
> using the REST endpoints to run/submit jobs, causing confusion on the
> actual state of the submitted jobs in a cluster.
>
> I've created a PR against the "master" branch, and I'd like to be able to
> port it back to 1.16.2 and 1.15.4 to close the loop on the issue for the
> last three major releases:
> https://github.com/apache/flink/pull/21849
>
> Cheers,
> Mohsen Rezaei
>
> ---------- Forwarded message ---------
> From: Mohsen Rezaei <mo...@gmail.com>
> Date: Sat, Jan 21, 2023 at 5:58 PM
> Subject: Duplicate jobs on /run with the same jobId
> To: <de...@flink.apache.org>
>
>
> Hi everyone,
>
> I have run into an issue with the Dispatcher's runJob() that accepts
> multiple jobs and starts them with the same jobId.
>
> The filtering fix in waitForTerminatingJob [1] fixes the issue, but I need
> a consensus from devs to ensure this is the proper fix, before submitting a
> PR.
>
> Cheers,
> Mohsen Rezaei
>
> [1] https://issues.apache.org/jira/browse/FLINK-30596
>