This is an automated email from the ASF dual-hosted git repository. xtsong pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/flink-agents.git
commit cc2171599267ba4ab70aa1c4f0b73e2604c5b03a Author: WenjinXie <[email protected]> AuthorDate: Thu Jan 29 14:45:25 2026 +0800 [runtime] Cancel pending futures when shutdown async executor. --- python/flink_agents/runtime/flink_runner_context.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/python/flink_agents/runtime/flink_runner_context.py b/python/flink_agents/runtime/flink_runner_context.py index c4b06c10..7591c062 100644 --- a/python/flink_agents/runtime/flink_runner_context.py +++ b/python/flink_agents/runtime/flink_runner_context.py @@ -568,4 +568,4 @@ def create_async_thread_pool(max_workers: int | None) -> ThreadPoolExecutor: def close_async_thread_pool(executor: ThreadPoolExecutor) -> None: """Used to close the thread pool.""" - executor.shutdown() + executor.shutdown(cancel_futures=True)
