我建了一个jira,建议sql client把作业提交到各种集群的方式在文档里写清楚,
可以关注 https://issues.apache.org/jira/browse/FLINK-23483

Best,
Godfrey


Caizhi Weng <tsreape...@gmail.com> 于2021年7月23日周五 上午10:12写道:

> Hi!
>
> 可以考虑把 k8s session 的 flink rest api 地址暴露出来,然后客户端把 execution.target 设为
> remote,rest.address 和 rest.port 设为相应地址。
>
> maker_d...@foxmail.com <maker_d...@foxmail.com> 于2021年7月22日周四 下午9:46写道:
>
> > 大家好,
> >     我将flink部署在k8s集群上,使用官方文档上的session模式进行部署,可以正常提交任务。
> >     现在我想使用sqlclient,在提交任务时提示 :
> >         [ERROR] Could not execute SQL statement. Reason:
> >         java.net.UnknownHostException: flink-cluster
> >     请问大家,如何使用sqlclient连接k8s上的flink session。
> >     flink版本 1.12.4.
> >
> >
> >
> > maker_d...@foxmail.com
> >
>

回复