安装Flink

在物理机上部署并配置Flink，使其能够运行在多个Docker容器中，以便后续可以提交并运行Flink作业。

1. 进入物理机的“/usr/local”目录并下载Flink软件部署包。

   1 2	cd /usr/local wget --no-check-certificate https://archive.apache.org/dist/flink/flink-1.16.3/flink-1.16.3-bin-scala_2.12.tgz

   

   flink-1.16.3-bin-scala_2.12.tgz为Flink软件包名称，如果使用的是其他版本的Flink，请根据实际情况修改。

2. 到“/usr/local”目录解压flink-1.16.3-bin-scala_2.12.tgz，建立软链接，便于后期版本更换。

   1 2 3

   tar -zxvf flink-1.16.3-bin-scala_2.12.tgz chown -R root:root flink-1.16.3 ln -s flink-1.16.3 flink

   

   flink-1.16.3为Flink软件目录名称，如果使用的是其他版本的Flink，请根据实际情况修改。

3. 配置Flink的masters和workers文件。
   1. 打开“/usr/local/flink/conf/masters”文件。

      1	vi /usr/local/flink/conf/masters

   2. 按“i”进入编辑模式，将masters内容修改为容器flink_jm_8c32g的容器ID:8081，例如：

      1	4a376b30106b:8081

   3. 按“Esc”键，输入:wq!，按“Enter”保存并退出编辑。
   4. 打开“/usr/local/flink/conf/workers”文件。

      1	vi /usr/local/flink/conf/workers

   5. 按“i”进入编辑模式，将workers内容修改为flink_tm1_8c32g、flink_tm2_8c32g容器的容器ID，例如（2个Docker容器，每个Docker 4个Task Manager配置）：

      1 2 3 4 5 6 7 8

      c3ddf10d0353 c3ddf10d0353 c3ddf10d0353 c3ddf10d0353 c3bbdbcc1ae1 c3bbdbcc1ae1 c3bbdbcc1ae1 c3bbdbcc1ae1

   6. 按“Esc”键，输入:wq!，按“Enter”保存并退出编辑。
   7. 打开“/usr/local/flink/conf/flink-conf.yaml”文件。

      1	vi /usr/local/flink/conf/flink-conf.yaml

   8. 按“i”进入编辑模式，替换为如下配置，并将jobmanager.rpc.address修改为容器flink_jm_8c32g的容器ID，建议配置的slot总数大于并行度，例如：

      taskmanager.memory.process.size: 8G
      jobmanager.rpc.address: 4a376b30106b
      jobmanager.rpc.port: 6123
      jobmanager.memory.process.size: 8G
      taskmanager.memory.process.size: 8G
      taskmanager.numberOfTaskSlots: 2
      parallelism.default: 16
      rest.port: 8081
      rest.bind-port: 8081
      io.tmp.dirs: /tmp
      #pipeline.operator-chaining: true
      #execution:runtime-mode: STREAMING
      #jobmanager.execution.failover-strategy: region
      #table.optimizer.agg-phase-strategy: ONE_PHASE
      #pipeline.object-reuse: true
      #==============================================================================
      # JVM
      #==============================================================================
      # JVM options for GC
      #env.java.opts: -verbose:gc -XX:NewRatio=3 -XX:+PrintGCDetails -XX:+PrintGCDateStamps -XX:ParallelGCThreads=4

   9. 按“Esc”键，输入:wq!，按“Enter”保存并退出编辑。