1.3.Flink本地安裝
1.3.1.分別解壓scala和Flink
1.3.2.配置環(huán)境變量
1.3.3.啟動集群
1.3.4.提交一個job
1.3.5.停止集群

1.3.Flink本地安裝

如果想安裝FLink，只需要安裝Java8或11，可以通過執(zhí)行下面的命令檢查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.配置環(huán)境變量

# 設(shè)置scala環(huán)境變量 export SCALA_HOME=/home/admin/installed/scala-2.12.12 export PATH=$PATH:$SCALA_HOME/bin# 設(shè)置flink環(huán)境變量 export FLINK_HOME=/home/admin/installed/flink-1.11.1 export PATH=$PATH:$FLINK_HOME/binsource /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的發(fā)行版本中包含一些列的例子job。你可以快速的部署一個應(yīng)用到運(yùn)行中的集群中

$ ./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的方式查看運(yùn)行情況：http://ip:8081/#/overview

1.3.5.停止集群

$ ./bin/stop-cluster.sh

在Flink中主節(jié)點(diǎn)叫做jobManager，從節(jié)點(diǎn)交過TaskManager

總結(jié)

以上是生活随笔為你收集整理的03_Flink本地安装、分别解压scala和Flink、配置环境变量、启动集群、提交一个job、停止集群的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。