大家好,请教个问题。

用native kubernetes方式在k8s集群上部署好了flink,现在需要在这个flink集群里使用flink sql 
gateway,大家有什么好的方案吗?
目前的做法是,进入pod里启动sql gateway,然后在k8s创建flink-sql-gateway 
service,这样就可以通过这个service来访问sql 
gateway了,但是这个方法有个问题,部署过程中必需进入pod启服务,这是不利于自动化部署的,具体的操作命令如下,大家帮忙看看有没有好的解决方案来避免这个问题。


1、创建flink集群
./bin/kubernetes-session.sh \
-Dkubernetes.cluster-id=flink-cluster \
-Dkubernetes.namespace=flink \
-Dkubernetes.service-account=flink-service-account \
-Dkubernetes.rest-service.exposed.type=NodePort


2、进入pod通过 ./bin/sql-gateway.sh start 
-Dsql-gateway.endpoint.rest.address=localhost 启动sql gateway服务,退出pod


3、创建flink-sql-gateway service
kubectl expose deployment flink-cluster --type=NodePort --port=8083 
--name=flink-sql-gateway -n flink

Reply via email to