03_Flink本地安装、分别解压scala和Flink、配置环境变量、启动集群、提交一个job、停止集群

Myth丶恋晨 2023-01-03 04:04 89阅读 0赞

1.3.Flink本地安装  
1.3.1.分别解压scala和Flink  
1.3.2.配置环境变量  
1.3.3.启动集群  
1.3.4.提交一个job  
1.3.5.停止集群

## 1.3.Flink本地安装 ##

如果想安装FLink，只需要安装Java8或11，可以通过执行下面的命令检查java的安装：

java -version

下载

wget https://downloads.lightbend.com/scala/2.12.12/scala-2.12.12.tgz
    wget https://mirrors.bfsu.edu.cn/apache/flink/flink-1.11.1/flink-1.11.1-bin-scala_2.12.tgz

### 1.3.1.分别解压scala和Flink ###

解压位置为：/home/admin/installed  
如下：

[root@xxxx1 installed]# pwd
    /home/admin/installed
    [root@xxxx1 installed]# ls
    flink-1.11.1  scala-2.12.12
    [root@xxxx1 installed]#

### 1.3.2.配置环境变量 ###

# 设置scala环境变量
    export SCALA_HOME=/home/admin/installed/scala-2.12.12
    export PATH=$PATH:$SCALA_HOME/bin
    
    # 设置flink环境变量
    export FLINK_HOME=/home/admin/installed/flink-1.11.1
    export PATH=$PATH:$FLINK_HOME/bin
    
    source /etc/profile

### 1.3.3.启动集群 ###

$ cd $FLINK_HOME/
    $ ./bin/start-cluster.sh
    Starting cluster.
    Starting standalonesession daemon on host.
    Starting taskexecutor daemon on host.

Web UI的地址：http://ip:8081/\#/job/completed

### 1.3.4.提交一个job ###

Flink的发行版本中包含一些列的例子job。你可以快速的部署一个应用到运行中的集群中

$ ./bin/flink run examples/streaming/WordCount.jar
    $ tail log/flink-*-taskexecutor-*.out
      (to,1)
      (be,1)
      (or,1)
      (not,1)
      (to,2)
      (be,2)

除此之外，你可以访问Web UI的方式查看运行情况：http://ip:8081/\#/overview

### 1.3.5.停止集群 ###

$ ./bin/stop-cluster.sh

在Flink中主节点叫做jobManager，从节点交过TaskManager