微信公众号:深广大数据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服务
关注公众号
领取专属 10元无门槛券
私享最新 技术干货