CentOS7:启动Apache Flink

Posted 你是小KS

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了CentOS7:启动Apache Flink相关的知识,希望对你有一定的参考价值。

1.声明

当前内容主要用于本人学习Apache Flink,内容主要借鉴Apache Flink的官方文档

需要环境:JDK1.8

主要内容为:

  1. 下载和在CentOS7中启动Apache Flink
  2. 开放端口和访问Web UI版的Apache Flink

2.下载启动Apache Flink

1.下载(flink-1.13.0-bin-scala_2.11.tgz),地址:Apache Flink

2.将下载的包上传到Linux中

3.解压:

tar -xvif flink-1.13.0-bin-scala_2.11.tgz

4.修改配置文件(conf/flink.yaml)

cd flink-1.13.0/
vi conf/flink.yaml

在这里插入图片描述
heartbeat.timeout:180000,这个是用于控制任务执行过程中的超时时间!

其他需要添加的配置查看:官方配置文档

5.开放webui端口(8081)

firewall-cmd --zone=public --add-port=8081/tcp --permanent
//重启防火墙
systemctl restart firewalld.service
//重载配置文件
firewall-cmd --reload

6.启动Apache Flink(单机版的)

./bin/start-cluster.sh

在这里插入图片描述

7.访问
http://访问Linux的ip地址:8081/#/overview

结果
在这里插入图片描述

3.关闭Flink

./bin/stop-cluster.sh

在这里插入图片描述

以上是关于CentOS7:启动Apache Flink的主要内容,如果未能解决你的问题,请参考以下文章

flink1.11报错:java.lang.IllegalStateException: No ExecutorFactory found to execute the application(代码片

无法在Google Cloud Dataproc上启动Apache Flink 1.7

在 Apache Flink 中动态添加模式而不重新启动作业

CDH6.3.2集成Apache Flink1.12.0

CDH6.3.2集成Apache Flink1.12.0

日常Exception第二十五回:Flink启动job时报错,AbstractChannel$AnnotatedConnectException: Connection refused.....(代码