# flink

**Repository Path**: lightsoft/flink

## Basic Information

- **Project Name**: flink
- **Description**: No description available
- **Primary Language**: Java
- **License**: Apache-2.0
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 1
- **Forks**: 0
- **Created**: 2024-07-16
- **Last Updated**: 2024-07-18

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

### 下载flink
wget https://dlcdn.apache.org/flink/flink-1.19.1/flink-1.19.1-bin-scala_2.12.tgz
### 解压至/opt/flink-1.19.1
tar -zxvf flink-1.19.1-bin-scala_2.12.tgz /opt/flink-1.19.1

| 节点服务器IP | 节点服务器 | 角色 |
| :------ | :------ | :------ |
| 192.168.19.200 | hadoop102 | JobManager、TaskManager |
| 192.168.19.201 | hadoop103 | TaskManager |
| 192.168.19.202 | hadoop104 | TaskManager |

## 方式一：物理机
(1)vi /opt/flink-1.19.1/conf/config.yaml

```
# JobManager节点地址
jobmanager.rpc.address: hadoop102
jobmanager.bind-host: 0.0.0.0
rest.address: hadoop102
rest.bind-address: 0.0.0.0
```

```
# TaskManager节点地址
taskmanager.bind-host: 0.0.0.0
taskmanager.host: hadoop102 # 需要配置为当前机器名
```

(2)vi /opt/flink-1.19.1/conf/workers
```
hadoop102
hadoop103
hadoop104
```
(3)vi /opt/flink-1.19.1/conf/masters
```
hadoop102:8081
```

## 方式二：docker

```
mkdir -p /docker/flink/jobmanager/conf
mkdir -p /docker/flink/taskmanager1/conf
mkdir -p /docker/flink/taskmanager2/conf
```

同 **方式一** 生成JobManager、TaskManager配置文件,分别放到对应角色/docker/flink/xxx/conf目录下

```
docker network create flink-network

docker run -d -p 8081:8081 --name flink-jobmanager --network flink-network -v /home/debo/dockerData/flink/jobmanager/conf/config.yaml:/opt/flink/conf/config.yaml flink:scala_2.12-java8 jobmanager
docker run -d --name flink-taskmanager1 --network flink-network -v /home/debo/dockerData/flink/jobmanager/conf/config.yaml:/opt/flink/conf/config.yaml flink:scala_2.12-java8 taskmanager
docker run -d --name flink-taskmanager2 --network flink-network -v /home/debo/dockerData/flink/jobmanager/conf/config.yaml:/opt/flink/conf/config.yaml flink:scala_2.12-java8 taskmanager
```