Flink初体验

Posted 2022-02-09 她说：斯文败类

软件安装版本号说明:

JDK：1.8.0_302

Flink：flink-1.14.2-bin-scala_2.11

linux：CentOS 7.0

一、安装

1.官网下载(https://flink.apache.org/downloads.html) Apache Flink 1.14.2 for Scala 2.11版本

2.上传至服务器并解压文件

tar -xvf flink-1.14.2-bin-scala_2.11.tgz

3.启动Flink

cd $FLINK_HOME
./bin/start-cluster.sh Starting cluster

进入flink下bin目录执行start-cluster.sh脚本启动Flink(暂不用修改配置)

二、初体验

1.在浏览器键入http://ip:8081 进入Flink Web UI

 2.在Flink 1.14.2 二进制发布包中官方已经提供了部分demo供用户测试和体验，我们可以在flink目录下examples中找到。本次体验使用经典、简单的WordCount.jar

 3.运行测试示例

cd $FLINK_HOME
/bin/flink run ./examples/streaming/WordCount.jar

4.检查Flink Web UI "Job -> Runing Jobs"中的作业

5.如果应用是流式的,它会一直运行下去,直到你手动取消。取消的方式是在UI中选定作业，然后点击Cancel按钮。

6.如果作业是批量的，在作业结束后作业状态更改为FINISHED，可以在Flink Web UI "Job -> Completed Jobs"中查看。

 7.关闭Flink服务

cd $FLINK_HOME
./bin/stop-cluster.sh

       未完待续...