bowenli86 commented on PR #29155: URL: https://github.com/apache/flink/pull/29155#issuecomment-5650764975
@dianfu Added a centralized guard in both `get_gateway()` and `launch_gateway()`. It checks for Pemja's native `_pemja` module before acquiring the gateway lock, returning a cached gateway, or connecting/launching. Embedded callers now get a `RuntimeError` directing them to `pemja.findClass`; importing the installable `pemja` package in an ordinary client does not trigger the guard. The regressions cover both entry points, cached/port-configured gateways, and unchanged client/process-worker behavior. The embedded test also verifies a Java call through Pemja. The focused suite passes 9 tests and 15 subtests, and the exact embedded worker functions passed standalone Linux red/green checks with Flink 2.3.0 and Pemja 0.5.7. The FLINK-40631 fixture was a temporary workaround for the unrelated `CalcRestoreTest` failure. Master now contains the proper fix in 1d6a308844678a2658d0af513dc32b7f0da38711, so I rebased onto e01bbcacd962189c726d8324a35d66cc162712e7 and removed the fixture/revert commits. This PR now contains only two focused FLINK-40628 commits and five Python files. Fresh Azure CI is pending for 7db42d567feb3699f1b36201aa51cef7e926146f. -- 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]
