Python Flink подключается к удаленной среде Flink

У меня есть система flink, работающая в удаленной системе ... скажем, с IP как 10.XX.XX.XX и портом как 6123. Теперь я хотел бы подключиться из другой системы, используя Pyflink, используя RemoteExecution Environment. Я видел документы https://ci.apache.org/projects/flink/flink-docs-stable/dev/python/table-api-users-guide/table_environment.html, но это не ясно. Любые указатели, пожалуйста?


apache-flink flink-streaming flink-sql pyflink
person Arun Chandramouli    schedule 08.04.2021    source источник

Ответы (1)


arrow_upward
1
arrow_downward

Я считаю, что для этого должно быть достаточно:

./bin/flink run \
      --jobmanager <jobmanagerHost>:8081 \
      --python examples/python/table/batch/word_count.py

См. Отправка заданий PyFlink, где я нашел этот пример.

person David Anderson    schedule 08.04.2021
comment
Я попробую, есть ли такой пример в Python, похожий на java - ci.apache.org/projects/flink/flink-docs-release-1.1/apis/? - person Arun Chandramouli; 08.04.2021
comment
Я не думаю, что вы можете явно принудительно создать среду удаленного выполнения, как в Java. Но он будет использовать один, если он есть. Подробную информацию о возможностях см. В документации по API: ci.apache.org/projects/flink/flink-docs-master/api/python/ - person David Anderson; 08.04.2021