Flink-MAC本地模式搭建

查看Java版本

由于Flink要求Java 7.x以上的版本，所以在本地安装前先检查自己的Java版本

java -version

利用Homebrew安装

mac使用Homebrew安装非常快捷，一行命令安装成功。如果没有安装Homebrew，请移步Homebrew安装

第一次使用可能会失败，这时根据提示更新下Homebrew

brew update

然后执行：

brew install apache-flink

完成之后验证：

flink --version

结果如图：

这样有时候我们安装完成之后找不到安装路径在哪，这时候我们可以利用which命令来查找。

进入上述目录执行ll *flink*

目录结构如下：

到此本地安装已经完成。接下来跑个demo试试。

DEMO

一、本地启动flink

./bin/start-local.sh

启动脚本如果报错找不到FLINK_BIN_DIR，进行如下尝试：

二、UI

访问localhost:8081进入UI进行查看（本地需要有localhost到127.0.0.1绑定）

三、提交Job

提交官方的demo时，mac本地启动一个本地的服务

nc -l 9000

1、UI提交

2、命令行提交

flink run -c com.thelearning.flink.SocketWindowWordCount /Users/youhaibo/tony_github/flink_learning/target/flink-examples-1.0.0-SNAPSHOT.jar --port 9000

四、验证Job执行

1、UI查看结果

2、查看运行日志

参考

Flink Quick Start