跳至主要內容

Flink部署

xw小于 1 分钟开源框架Flink

Docker方式

采用docker部署,taskmanager可部署一到多个。

FLINK_PROPERTIES="jobmanager.rpc.address: jobmanager"
## 创建网络
docker network create flink-network

## 启动jobmanager
docker run \
    -d \
    --restart=always \
    --name=jobmanager \
    --network flink-network \
    --publish 8081:8081 \
    --env FLINK_PROPERTIES="${FLINK_PROPERTIES}" \
    flink:1.13.1 jobmanager

## 启动taskmanager-1
docker run \
    -d \
    --restart=always \
    --name=taskmanager-1 \
    --network flink-network \
    --env FLINK_PROPERTIES="${FLINK_PROPERTIES}" \
    flink:1.13.1 taskmanager    

## 启动taskmanager-2
docker run \
    -d \
    --restart=always \
    --name=taskmanager-2 \
    --network flink-network \
    --env FLINK_PROPERTIES="${FLINK_PROPERTIES}" \
    flink:1.13.1 taskmanager  

## 启动taskmanager-3  
docker run \
    -d \
    --restart=always \
    --name=taskmanager-3 \
    --network flink-network \
    --env FLINK_PROPERTIES="${FLINK_PROPERTIES}" \
    flink:1.13.1 taskmanager       

访问 [ip:8081](http://{ip}:8081](http://{ip}:8081/).