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



目前,我有一个正在运行的Flink Kubernetes会话集群(Flink版本1.13.2),我也可以通过port-forward访问web UI,我可以通过这个命令./bin/flink run -m localhost:8081 examples/batch/WordCount.jar从我的本地环境提交WordCount jar示例。

但是当我尝试通过命令./bin/flink run -m localhost:8081 -py examples/python/table/batch/word_count.py提交pyFlink示例时,作业冻结,日志说正在等待结果。

我尝试了很多方法,包括创建virtualenv,传递pyClientExecutable和pyexec,同步本地和远程python版本,但是,没有一个工作。

我错过了什么?如何向远程会话集群提交python示例?

注意 :当我在作业管理器pod中提交pyFlink word_count示例时,它运行没有任何问题。

我手头没有Flink-1.13;但是,在Flink-1.15中的相同示例中有一行注释提醒您删除.wait

最新更新