Flink下载
为了运行Flink,需提前安装好 Java 8 或者 Java 11,通过以下命令来检查 Java 是否已经安装正确。
命令:
java -version
如果出现下面JDK版本信息:
java version “1.8.0”
说明安装好了Java,就可以开始下载Flink了:
$ wget https://archive.apache.org/dist/flink/flink-1.15.3/flink-1.15.3-bin-scala_2.12.tgz
Flink解压
命令:
$ tar xzf flink-1.15.3-bin-scala_2.12.tgz
Flink配置
进入Flink目录,修改配置文件
$
cd flink-1.15.3
修改配置文件:
$ vim conf/flink-conf.yaml
配置地址:把localhost改成具体的ip地址
rest.address: xxx.xxx.xxx.xxx rest.bind-address: xxx.xxx.xxx.xxx
Flink启动
Flink附带了一个 bash 脚本,可以用于启动本地集群。
启动命令:
bin/start-cluster.sh
启动提示:
Starting cluster. Starting standalonesession daemon on host.
启动成功后,可以访问Flink 的 Web UI :
http://配置的ip:8081/
比如:你是本地:localhost:8081
访问地址,如下图所示:
出现上图界面,说明Flink安装成功了。