2017-10-28 144 views
0

有没有人曾经成功地运行python和windows使用flink?是否可以在Windows上使用pyflink?

我想下面的命令:

.\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. 
+0

请分享一些你已经试过的更多细节(版本号等)以及你得到的全部错误。 –

+0

正在执行的精确命令以及上面添加的结果错误。版本为Windows 10 x64上的版本:1.3.2,提交ID:0399bee。 – pokegoer

回答

0

程序不包含弗林克工作。也许你忘记了在执行环境中调用 execute()。

这看起来像你忘了添加

env.execute(local=True)

你是在本地运行它的情况。没有这个flink作业将无法执行。你可以通过这个找到更多的信息simple example program

+0

我已经用你提到的简单示例程序和local = True参数进行了尝试。我注意到,提供给pyflink的文件名是无关紧要的。我总是得到同样的错误。我可以键入'''pyflink nonExistentFile.py''',我会得到相同的错误。 – pokegoer

相关问题