hutiefang76 commented on PR #12510: URL: https://github.com/apache/seatunnel/pull/12510#issuecomment-5861373037
I checked the direct `restorePipelineState()` call and reproduced the escaping exception in a public-entry test. Fixed in f135f7ceb: allocation failure now calls `makePipelineFailing(...)` and returns locally, so it no longer depends on the caller's catch. I also added the required task-group slot count to the message and a comment explaining the stale futures. The tests now use public entry points. They check that both FAILED and CANCELED pipelines enter FAILING without aborting the remaining pipeline restore, consume a retry, and can restore when capacity becomes available. The earlier throw-based commit fails two of the four tests; the updated code passes all four. JDK 17 passed 19 focused/neighboring tests and reactor verify; JDK 8 passed the four focused tests and reactor verify. The success and exhausted-budget tests remain compatibility controls. This covers the pipeline takeover entry with mocked services, rather than claiming a live Master-loss test. -- 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]
