Apache Flink本地安装及Example运行

微信公众号：深广大数据Club

关注可了解更多大数据相关的资讯。问题或建议，请公众号留言;

如果你觉得深广大数据Club对你有帮助，欢迎赞赏[1]

Apache Flink部署模式有好几种，本文主要介绍Apache Flink的本地部署模式。

本地部署模式主要用于开发者程序调试测试使用。

先决条件

运行系统：系统方面没有过多要求，Linux、Mac、Windows均可

Java 1.8.x以上，Apache Flink不支持1.8.x以下的版本。

检查系统的Java版本

下载、启动Flink

下载

进入Apache Flink官网下载安装包。下载地址：https://flink.apache.org/downloads.html

我们下载Apache Flink的最新包1.6.2版本

解压

配置环境变量

在~/.bash_profile文件中添加以下变量：

启动Flink

通过web前端检查服务是否正常运行

http://localhost:8081

Web前端可以看到有一个可用的TaskManager实例。

还可以通过检查logs目录中的日志文件来验证系统是否正在运行：

运行example

首先，我们使用netcat来启动本地服务器

提交Flink工程

程序连接到socket端口并等待输入。 可以检查Web界面以验证作业是否按预期运行：

单词在5秒的时间窗口中计算（处理时间，翻滚窗口）并打印到标准输出。 监视TaskManager的输出文件并在nc中写入一些文本（输入在点击后逐行发送到Flink）：

.out文件会在每个时间窗口的末尾打印计数

停止Flink服务

关注公众号