废话
单机版安装方式也很简单,下载下来,跑一下命令就行。
集群方式……这里是在单个机器上的集群方式
开搞
1. 装docker
略
2. 装个pip
安装
sudo apt-get install pip
检查
pip -v
3. 装个docker-compose
主要是通过pip来安装
sudo pip install docker-compose
检查
docker-compose -v
4. 下载flink镜像
docker pull flink
5. 创建docker-compose.yml文件
我这里目录是/opt/flink/
vi /opt/flink/docker-compose.yml
文件内容
version: "2.1"
services:
jobmanager:
image: flink
expose:
- "6123"
ports:
- "8081:8081"
command: jobmanager
environment:
- JOB_MANAGER_RPC_ADDRESS=jobmanager
taskmanager:
image: flink
expose:
- "6121"
- "6122"
depends_on:
- jobmanager
command: taskmanager
links:
- "jobmanager:jobmanager"
environment:
- JOB_MANAGER_RPC_ADDRESS=jobmanager
6. 安装并启动
启动
docker-compose up -d
搞2个节点,你要几个就把2改成几就行。
docker-compose scale taskmanager=2
7. 打开localhost:8081看看,能正常访问且节点数正常就是没问题。
8. 强制关闭
查一下相关进程id,强制关掉就行。
#查进程列表
ps -aux |grep flink
#根据进程id关闭进程
kill -9 xxx