【问题标题】:Is it possible to use pyflink on windows?是否可以在 Windows 上使用 pyflink?
【发布时间】:2020-05-26 12:00:59
【问题描述】:

有没有人用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.

【问题讨论】:

  • 请分享更多关于您尝试过的内容(版本号等)以及您遇到的完整错误的详细信息。
  • 正在执行的确切命令和上面添加的结果错误。版本是版本:1.3.2,提交 ID:Windows 10 x64 上的 0399bee。

标签: apache-flink pyflink


【解决方案1】:

该程序不包含 Flink 作业。也许你忘了打电话 在执行环境上执行()。

你好像忘记添加了

env.execute(local=True)

如果您在本地运行它。没有这个,flink 作业将无法执行。您可以通过此simple example program 找到更多信息

【讨论】:

  • 我已经用你提到的简单示例程序和 local=True 参数进行了尝试。我注意到提供给 pyflink 的文件名是无关紧要的。我总是遇到同样的错误。我可以输入pyflink nonExistentFile.py,我会得到同样的错误。
  • 我面临同样的问题。有什么帮助吗?
【解决方案2】:

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

【讨论】:

    【解决方案3】:

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

    【讨论】:

      猜你喜欢
      • 1970-01-01
      • 2013-08-30
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 2016-09-29
      • 1970-01-01
      • 2014-06-08
      • 1970-01-01
      相关资源
      最近更新 更多