Можно ли использовать 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