我有一个在远程系统中运行的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作业,这就是我发现这个例子的地方。