如何向远程Kubernetes Flink会话集群提交pyFlink作业？

你遇到的问题本质是PyFlink和Java Jar作业的提交逻辑不同：Jar作业仅依赖JobManager的8081 REST端口即可完成提交，PyFlink还需要额外的Python RPC通信端口、依赖分发配置，1.13.x版本的特有配置缺失是卡住的核心原因，按以下步骤排查修复即可：

1. 打通PyFlink RPC端口 #

默认PyFlink使用随机端口进行Python网关通信，仅forward 8081端口无法满足通信要求，需要先固定端口范围并同步forward：

• 提交作业时添加端口配置参数：

./bin/flink run -m localhost:8081 \
-Dpython.gateway.port=5555-5560 \
-Dpython.client.executable=<集群侧Python可执行文件路径> \
-Dpython.executable=<集群侧Python可执行文件路径> \
-py examples/python/table/batch/word_count.py

• 同步在本地开启对应端口的port-forward：

kubectl port-forward svc/<你的Flink JobManager服务名> 8081 5555:5555 5556:5556 5557:5557 5558:5558 5559:5559 5560:5560

2. 显式上传Python依赖包 #

本地提交时PyFlink不会自动同步本地Python环境到集群，需要手动打包虚拟环境随作业提交：

1. 打包和集群Python版本完全一致的本地虚拟环境（需提前安装apache-flink==1.13.2、apache-flink-libraries==1.13.2依赖）：

zip -r venv.zip <你的虚拟环境目录>

2. 提交作业时添加虚拟环境参数：

./bin/flink run -m localhost:8081 \
-Dpython.gateway.port=5555-5560 \
-Dpython.client.executable=venv/bin/python \
-Dpython.executable=venv/bin/python \
-pyarch venv.zip#venv \
-py examples/python/table/batch/word_count.py

3. 集群侧基础依赖检查 #

确认所有JobManager、TaskManager节点的Python环境已安装和集群Flink版本完全匹配的PyFlink依赖，版本不匹配会直接导致作业卡住无返回。

替代方案 #

如果不想配置多端口forward，可以直接在K8s集群内部的节点上提交作业，内部网络无端口限制，和你直接在JobManager Pod内提交能正常运行的逻辑一致。

内容的提问来源于stack exchange，提问作者Amin