- In pemja python thread, we get a java object, and then we passed it to a python asynchronous thread.
- In the async thread, when we call the method of this java object, if the method returns a custom java object, the jvm will crash; If the method returns jdk built-in object, like string or List, it will work normally.
How to reproduce
clone https://github.com/wenjin272/flink-agents/tree/built-in-async
./tools/build.sh
pip install apache-flink==1.20.3
uv run pytest python/flink_agents/e2e_tests/e2e_tests_integration/react_agent_test.py::test_react_agent_on_remote_runner
Here is the err file:
long_text_a1b36098-7418-4bdb-b9cf-ed8e7469ecb2.txt