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 <[email protected]> Date: Sat, Jan 21, 2023 at 5:58 PM Subject: Duplicate jobs on /run with the same jobId To: <[email protected]> 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
