Python Flink连接到远程Flink环境



我有一个在远程系统中运行的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但目前还不清楚。有什么建议吗?

似乎没有通过编程实现这一点的内置方法,但我可以直接使用:

from pyflink.java_gateway import get_gateway
gateway = get_gateway()
string_class = gateway.jvm.String
string_array = gateway.new_array(string_class, 0)
stream_env = gateway.jvm.org.apache.flink.streaming.api.environment.StreamExecutionEnvironment
j_stream_exection_environment = stream_env.createRemoteEnvironment(
"localhost", 
8081, 
string_array
)
env = StreamExecutionEnvironment(j_stream_exection_environment)

我认为这样做就足够了:

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

请参阅提交PyFlink作业,这就是我发现这个例子的地方。

相关内容

  • 没有找到相关文章

最新更新