Можно ли использовать pyflink на windows?

Кто-нибудь когда-либо имел успех в использовании 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 ответ

Программа не содержала работу Flink. Возможно, вы забыли вызвать execute() в среде выполнения.

Похоже, вы забыли добавить

env.execute(local=True)

если вы используете его локально. Без этого задание Flink не сможет быть выполнено. Вы можете найти больше информации с помощью этого простого примера программы

В следующем выпуске 1.11 PyFlink будет поддерживать окна в локальном режиме. https://issues.apache.org/jira/browse/FLINK-12717

Я получил эту информацию в Win10. Возможно, в настоящее время он не поддерживается. htt ps:https://stackru.com/images/81425dee4b50c3359d8870467785c5b88d1c26a6.png

Другие вопросы по тегам