k8s session模式SQLclient怎样连接

["maker_dong@foxmail.com" <ma...@foxmail.com>]

大家好，
    我将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_dong@foxmail.com

Re: k8s session模式SQLclient怎样连接

[godfrey he <go...@gmail.com>]

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

Best,
Godfrey


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

> Hi！
>
> 可以考虑把 k8s session 的 flink rest api 地址暴露出来，然后客户端把 execution.target 设为
> remote，rest.address 和 rest.port 设为相应地址。
>
> maker_dong@foxmail.com <ma...@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_dong@foxmail.com
> >
>

Re: k8s session模式SQLclient怎样连接

[Caizhi Weng <ts...@gmail.com>]

Hi！

可以考虑把 k8s session 的 flink rest api 地址暴露出来，然后客户端把 execution.target 设为
remote，rest.address 和 rest.port 设为相应地址。

maker_dong@foxmail.com <ma...@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_dong@foxmail.com
>