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安装成功了。
陈睿mikechen
10年+大厂架构经验,资深技术专家,就职于阿里巴巴、淘宝、百度等一线互联网大厂。
关注「mikechen」公众号,获取更多技术干货!
后台回复【面试】即可获取《史上最全阿里Java面试题总结》,后台回复【架构】,即可获取《阿里架构师进阶专题全部合集》