flink连接到远程flink环境

mqxuamgl  于 2021-07-15  发布在  Flink
关注(0)|答案(1)|浏览(626)

我有一个远程系统在运行flink系统。。ip为10.xx.xx.xx,端口为6123。现在我想使用远程执行环境从另一个使用pyflink的系统进行连接。我看到医生了https://ci.apache.org/projects/flink/flink-docs-stable/dev/python/table-api-users-guide/table_environment.html 但还不清楚。有什么指示吗?

pokxtpni

pokxtpni1#

我认为这样做就足够了:

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

请参阅提交pyflink作业,这是我发现这个示例的地方。

相关问题