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服务

关注公众号

  • 发表于:
  • 原文链接https://kuaibao.qq.com/s/20181116G0JWN900?refer=cp_1026
  • 腾讯「云+社区」是腾讯内容开放平台帐号(企鹅号)传播渠道之一,根据《腾讯内容开放平台服务协议》转载发布内容。
  • 如有侵权,请联系 yunjia_community@tencent.com 删除。

扫码关注云+社区

领取腾讯云代金券