This is an automated email from the ASF dual-hosted git repository.
wenjin272 pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/flink-agents.git
The following commit(s) were added to refs/heads/main by this push:
new cfcd88f5 [python] Fix jar URI construction in execution_environment.py
(#1025)
cfcd88f5 is described below
commit cfcd88f5c9eccd5145d158c7b28fd43ff1def40f
Author: yanjin <[email protected]>
AuthorDate: Thu Aug 20 15:21:57 2026 +0800
[python] Fix jar URI construction in execution_environment.py (#1025)
---
python/flink_agents/api/execution_environment.py | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/python/flink_agents/api/execution_environment.py
b/python/flink_agents/api/execution_environment.py
index e9ffac9a..8750118f 100644
--- a/python/flink_agents/api/execution_environment.py
+++ b/python/flink_agents/api/execution_environment.py
@@ -137,7 +137,7 @@ class AgentsExecutionEnvironment(ABC):
if common_lib.is_dir():
for jar_file in common_lib.iterdir():
if jar_file.is_file() and str(jar_file).endswith(".jar"):
- env.add_jars(f"file://{jar_file}")
+ env.add_jars(jar_file.resolve().as_uri())
else:
err_msg = "Flink Agents common JAR not found."
raise FileNotFoundError(err_msg)
@@ -150,7 +150,7 @@ class AgentsExecutionEnvironment(ABC):
if version_lib.is_dir():
for jar_file in version_lib.iterdir():
if jar_file.is_file() and str(jar_file).endswith(".jar"):
- env.add_jars(f"file://{jar_file}")
+ env.add_jars(jar_file.resolve().as_uri())
else:
err_msg = f"Flink Agents dist JAR for Flink {major_version} not
found."
raise FileNotFoundError(err_msg)
