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

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/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的发行版本中包含一些列的例子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

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

Mac安装jdk1.8 / mysql5.7.16 与配置环境变量
目录一.下载jdk1.8版本 1.1 jdk安装 1.2 配置环境变量二.mysql版本下载一.下载jdk1.8版本 jdk8下载地址选择一款进行下载,我下载的是:jdk-8u291-maco ...
python27怎么安装thrift解压包_Python在Linux环境中安装Thrift
1.文件下载:thrift-0.11.0.tar.gz 个人网盘下载:链接:https://pan.baidu.com/s/1MXgx8LuN4wk7ssVUD9Wzaw 提取码:xw85 2. 将 ...
linux安装jdk配置环境变量之永久生效
首先,官网下载jdk包下载地址:https://www.oracle.com/cn/java/technologies/javase/javase8-archive-downloads.html 下 ...
java压缩包解压之后怎么安装_解压之后压缩包可以删除吗
1.在电脑正常安装解压缩软件的前提下,右键选择解压,将该文件解压到指定位置.2.解压完成后该文件即可正常运行,如果该文件是一般文档,打开即可查看或者使用,如果该文件是软件程序,选择setup.exe文 ...
Windows10 JDK9安装及配置环境变量与Eclipse安装
一下载JDK9 http://www.oracle.com/technetwork/java/javase/downloads/jdk9-downloads-3848520.html 选择版本,系统 ...
scala的下载以及环境变量配置（一）
下载地址:http://downloads.typesafe.com/scala/2.11.7/scala-2.11.7.msi 1.点击安装scala 安装好之后的文件 2.配置环境变量(设置 SC ...
java安装和配置环境变量
一.计算机的硬件与软件 1.计算机组成 2.cpu.内存.硬盘数据处理前都要加载到内存,然后通过cpu处理,之所以不从硬盘读取就是因为数据从磁盘读取慢,效率低.cpu从内存读数据时cpu从磁盘读取速 ...
Centos 安装 jdk 和配置环境变量
一安装jdk 1.浏览器进入 http://www.oracle.com/technetwork/java/javase/downloads/ 2.选择 jdk 1.8 3.选择接受,然后点击下载 ...
python需要配置环境变量吗_python安装和配置环境变量
Python 安装和配置环境变量一. Python 的安装: 在网上找一个 python 的安装包,我找的 python3.3.5 .照着安装步骤一步一步进行安装,完成后,运行 IDLE(Pyth ...