如何将 pyFlink 作业提交到远程 Kubernetes 会话集群？

Question

目前，我有一个正在运行的 Flink Kubernetes 会话集群（Flink 版本 1.13.2），我还可以通过以下方式访问 Web UI ，我可以通过此命令从本地环境port-forward提交 WordCount jar 示例。./bin/flink run -m localhost:8081 examples/batch/WordCount.jar

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

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

我缺少什么？如何将 python 示例提交到远程会话集群？

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

Answer 1

我手头没有Flink-1.13；然而，Flink-1.15 中的同一示例有一行注释提醒您删除.wait.