开始使用
集群验证
- 登录ECS弹性云服务器控制平台,选择{ecs_name}-manager01主管理节点的弹性云服务器,单击远程登录,或者使用其他的远程登录工具进入Linux弹性云服务器。
图1 登录ECS云服务器控制平台
图2 登录Linux弹性云服务器
- 在Linux弹性云服务中输入账号和密码后回车。
图3 登录ECS弹性云服务器
- 登录云容器引擎CCE平台,选择CCE集群,查看kubectl连接集群方式。
图4 查看集群状态信息,并查看kubectl连接集群方式
- 部署Flink operator
图5 查看集群连接情况图6 部署cert-manager
执行:kubectl apply -f cert-manager.yaml
kubectl -n cert-manager get pod
图7 部署Flink Operator执行:kubectl apply -f flink-operator.yaml
kubectl -n flink-operator-system get pod,svc
- pathFlink JobCluster 测试
部署Flink JobCluster
kubectl create -f flinkoperator_v1beta1_flinkjobcluster_volcano.yaml --validate=false
kubectl get pod,svc
图8 确认Job正确执行完成kubectl get pod
图9 确认Job由volcano调度执行命令:
kubectl get pod flinkjobcluster-sample-job-submitter-5jzzv -ojsonpath={'.spec.schedulerName'}
kubectl get pod flinkjobcluster-sample-jobmanager-0 -ojsonpath={'.spec.schedulerName'}
kubectl get pod flinkjobcluster-sample-taskmanager-0 -ojsonpath={'.spec.schedulerName'}