我让flink系统在远程系统中运行..假设IP为10.XX.XX.XX,端口为6123。现在我想通过RemoteExecution环境从另一个使用Pyflink的系统进行连接。我看过文档https://ci.apache.org/projects/flink/flink-docs-stable/dev/python/table-api-users-guide/table_environment.html,但不清楚。有什么建议吗?
发布于 2021-04-08 16:12:55
我相信这样做就足够了:
./bin/flink run \
--jobmanager <jobmanagerHost>:8081 \
--python examples/python/table/batch/word_count.py请参阅Submitting PyFlink Jobs,我就是在这里找到这个示例的。
https://stackoverflow.com/questions/66999654
复制相似问题