将 Flink SQL Client 连接到 Kubernetes 上的 Flink 集群

Question

我已经使用 Terraform 和 Helm 在 Kubernetes 上设置了 Flink 集群。我使用了 Flink Operator，并且还单独将 Flink SQL Client 下载到了我的机器上。

resource "helm_release" "flink_operator" {
  name       = "flink-kubernetes-operator"
  repository = "https://downloads.apache.org/flink/flink-kubernetes-operator-1.7.0/"
  chart      = "flink-kubernetes-operator"
  version    = "1.7.0"
}

问题： 现在，我想将 Flink SQL Client 连接到 Kubernetes 上正在运行的 Flink 集群并执行查询。我需要为此连接执行哪些步骤或配置？另外，如何验证SQL Client是否正确连接到Flink Cluster？

详情：

1. 我的豆荚：

NAMESPACE              NAME                                       READY   STATUS    RESTARTS        AGE
default                cert-manager-5669c8856-k52c7               1/1     Running   0               75m
default                cert-manager-cainjector-56c86fc86f-md559   1/1     Running   0               75m
default                cert-manager-webhook-84fffdf98-fdm4l       1/1     Running   0               75m
default                flink-kubernetes-operator-f4bbff6-5gsv4    2/2     Running   0               72m
kube-system            coredns-5d78c9869d-7vxwh                   1/1     Running   6 (15h ago)     6d20h
kube-system            coredns-5d78c9869d-t7zj9                   1/1     Running   6               6d20h
kube-system            etcd-docker-desktop                        1/1     Running   42 (15h ago)    6d20h
kube-system            kube-apiserver-docker-desktop              1/1     Running   46 (15h ago)    6d20h
kube-system            kube-controller-manager-docker-desktop     1/1     Running   60 (15h ago)    6d20h
kube-system            kube-proxy-nkl2r                           1/1     Running   6               6d20h
kube-system            kube-scheduler-docker-desktop              1/1     Running   116 (62m ago)   6d20h
kube-system            storage-provisioner                        1/1     Running   24 (61m ago)    6d20h
kube-system            vpnkit-controller                          1/1     Running   6               6d20h
kubernetes-dashboard   kubernetes-dashboard-b887d64f-jg52s        1/1     Running   1               4d

2. 我的服务：

NAMESPACE              NAME                             TYPE        CLUSTER-IP      EXTERNAL-IP   PORT(S)                  AGE
default                cert-manager                     ClusterIP   10.101.223.79   <none>        9402/TCP                 76m
default                cert-manager-webhook             ClusterIP   10.96.19.35     <none>        443/TCP                  76m
default                flink-operator-webhook-service   ClusterIP   10.96.137.93    <none>        443/TCP                  74m
default                kubernetes                       ClusterIP   10.96.0.1       <none>        443/TCP                  6d20h
kube-system            kube-dns                         ClusterIP   10.96.0.10      <none>        53/UDP,53/TCP,9153/TCP   6d20h
kubernetes-dashboard   kubernetes-dashboard             ClusterIP   10.96.230.173   <none>        443/TCP                  4d

3. 我已经使用以下指南在我的 Ubuntu 22.04 机器上成功设置了 Flink 集群：

• https://nightlies.apache.org/flink/flink-docs-master/docs/deployment/resource-providers/standalone/overview/

• https://developer.confluence.io/courses/apache-flink/stream-processing-exercise/

并将 Flink SQL 客户端连接到 Flink 集群。我感谢任何有关如何成功实现这种连接的指导或示例。谢谢！

Answer 1

目前还没有特别支持使用 FlinkOperator 提交 FlinkSQL 作业。尽管如此，还是有提交简单脚本的说明：https://github.com/apache/flink-kubernetes-operator/blob/main/examples/flink-sql-runner-example 我看到 IBM 使用相同的方法：ibm.github.io/event-automation/ep/advanced/deploying-product

PS，如果您已经成功，请分享您所做的事情