Apache Flink是一个面向分布式数据流处理和批量数据处理的开源计算平台,它能够基于同一个Flink运行时,提供支持流处理和批处理两种类型应用的功能。
使用brew安装
$ brew install apache-flink
$ flink –version
官网下载地址 https://flink.apache.org/downloads.html 下载flink
下载解压缩到指定目录
$ cd /Users/hhw/myapp/flink-1.7.0/bin
$ ./bin/start-cluster.sh
浏览器访问 http://localhost:8081/#/overview 可以看到Flink WebUI
查看启动日志
$ tail -f log/flink-*-taskexecutor-*local.out
官方例子,会从一个socket中读一段文本,并且每隔5秒打印每个单词出现的数量
$ nc -l 9000
$ ./bin/flink run examples/streaming/SocketWindowWordCount.jar --port 9000
查看输出日志
$ tail -f log/flink-*.out
$ bin/stop-cluster.sh