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 >
