从本文开始,我们将进入到Dinky的核心部分了,这里的核心部分是指的是如何使用Dinky来满足日常的业务工作研发/运维等工作。本文介绍的第一个是集群管理。
我们知道Dinky主要是一个基于Flink实现的实时计算平台,因此这里的话,Dinky他需要依赖Flink集群才能实现完整的功能,在实际的工作中,我们的Flink集群和Dinky是单独部署的,可能的部署情况是:
序号 | 服务器ip | 服务器部署 |
1 | 192.168.31.2 | dinky |
2 | 192.168.31.3 | Flink master |
3 | 192.168.31.4 | Flink worker1 |
4 | 192.168.31.5 | Flink worker2 |
上面的清单是一个简单的模拟环境,主要是体现的是Flink集群是一部分机器,Dinky是独立于Flink集群之外的实例。所以这里的话我们就需要在Dinky平台中注册Flink集群信息。
登录Dinky平台,点击注册中心->集群管理,可以如下图所示:
在Flink实例管理列表里面,我们可以添加一个Flink集群实例,点击新建:
然后在这里填写flink集群的信息即可,可以参考上面的提示来填写具体的信息,如下图:
这里我们在前面已经搭建过一个单机集群的Flink1.17版本,所以这里我们填写我们的集群信息:
填写完毕之后,我们就可以在列表中看到添加的集群了。
备注:
1、这里添加集群的时候需要选择类型,这里的类型有standalone,Yarn Session,Yarn Per-Job,Yarn Application,Kubernetes Session,Kubernetes Application,在填写的时候需要根据实际的flink运行模式来进行选择。 2、这里的心跳功能主要是手动的出发一次dinky和所选择的实例进行一次心跳,用来更改集群实例的状态。 3、回收这块一般没用,主要是回收自动注册到dinky上的per-job集群。一般用不到。
还没有评论,来说两句吧...