apache-flink - 是否可以在 Windows 上使用 pyflink？

Question

有没有人使用 python 和 windows 和 flink 成功运行过？

我正在尝试以下命令：

.\bin\pyflink.bat examples\python\WordCount.py

并得到以下错误

Starting execution of program
Usage: ./bin/pyflink<2/3>.[sh/bat] <pathToScript>[ <pathToPackage1>[ <pathToPackageX]][ - <parameter1>[ <parameterX>]]

The program didn't contain a Flink job. Perhaps you forgot to call execute() on the execution environment.

Answer 1

我在Win10中得到了这个信息。可能目前不支持。

Answer 2

该程序不包含 Flink 作业。也许您忘记在执行环境上调用 execute()。

这看起来像你忘了添加

env.execute(local=True)

如果您在本地运行它。没有这个，flink 作业将无法执行。您可以通过这个简单的示例程序找到更多信息

Answer 3

在接下来的 1.11 版本中，PyFlink 将支持本地模式下的窗口。https://issues.apache.org/jira/browse/FLINK-12717