wenjin272 opened a new issue, #692: URL: https://github.com/apache/flink-agents/issues/692
### Search before asking - [x] I searched in the [issues](https://github.com/apache/flink-agents/issues) and found nothing similar. ### Description In flink-agents, cross-language interaction between Python and Java relies on the pemja framework. Before pemja 0.5.7, errors or JVM crashes could occur when flink-agents performed cross-language interaction from an asynchronous thread. This issue was fixed in pemja 0.5.7: https://github.com/alibaba/pemja/pull/95. Since flink-agents depends on pemja transitively through PyFlink, adopting pemja 0.5.7 in flink-agents requires the following steps: 1. Bump the pemja version used by Flink. 2. Release a Flink version that includes this bump. 3. Update the Flink version that flink-agents depends on. Status: - Step 1 has been completed on Flink's 1.20, 2.x, and master branches: - 1.20: https://github.com/apache/flink/pull/28019 - 2.0: https://github.com/apache/flink/pull/28017 - 2.1: https://github.com/apache/flink/pull/28018 - 2.2, 2.3, and master: https://github.com/apache/flink/pull/28016 - Step 2: Flink 2.0.2 and 2.2.1 already include this bump, but no patch release containing the bump has been published yet for 1.20 or 2.1. - Step 3: The Flink patch version referenced under the dist directory has been updated accordingly. The remaining tasks are: 1. Release versions 1.20 and 2.1 that include the pemja upgrade. 2. Update the minor Flink version dependency in dist. ### Are you willing to submit a PR? - [ ] I'm willing to submit a PR! -- 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]
