CryoThrust opened a new pull request, #12052: URL: https://github.com/apache/seatunnel/pull/12052
### Purpose Fixes #12010. An interrupted pending-job insertion was previously swallowed by `PeekBlockingQueue.put`, allowing `submitJob` to complete successfully even though the job was not queued. ### Changes - Propagate `InterruptedException` from `PeekBlockingQueue.put` and restore the interrupt flag. - Let `CoordinatorService.submitJob` complete its future exceptionally through the existing error path and avoid advancing the physical plan to `PENDING`. - Apply the same explicit interruption handling to the master-switch restore path. - Add a deterministic regression test covering queue state, future completion, and job status. - Audited `take` and `peekBlocking`; they already propagate interruption. ### Verification - `git diff --check` passes. - Focused Maven compile/test could not start because the configured internal repository reset the connection and the HTTP plugin mirror was blocked by Maven. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
