docker安裝flink

1.拉取鏡像flink
docker pull flink
參考https://hub.docker.com/_/flink/


相關端口
The Web Client is on port 8081
JobManager RPC port 6123
TaskManagers RPC port 6122
TaskManagers Data port 6121

#創建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

#安裝docker-compose
見https://www.cnblogs.com/jasonzeng/p/12882912.html
生成啟動
cd /opt/flink/
docker-compose build
docker-compose up -d --force-recreate
docker-compose down
docker-compose restart


查看日志
docker logs --tail="500" flink_jobmanager_1
docker logs -f flink_taskmanager_1

查看進程
netstat -anltp|grep 8081

復制出配置文件
docker cp flink_jobmanager_1:/opt/flink/conf/ /opt/flink/conf_bak/

進入容器
docker exec -it --user root flink_jobmanager_1 /bin/bash

瀏覽器上查看頁面dashboard
http://192.168.0.1:8081

# 使用依賴
<dependencies>
    <dependency>
        <groupId>org.apache.flink</groupId>
        <artifactId>flink-java</artifactId>
        <version>1.9.2</version>
    </dependency>
    <dependency>
        <groupId>org.apache.flink</groupId>
        <artifactId>flink-streaming-java_2.11</artifactId>
        <version>1.9.2</version>
    </dependency>
    <dependency>
        <groupId>org.apache.flink</groupId>
        <artifactId>flink-clients_2.11</artifactId>
        <version>1.9.2</version>
    </dependency>
</dependencies>

 

轉自：www.cnblogs.com/wintersoft/p/11849518.html