Apache Flink Quickstart

原创
2017/05/22 14:54
阅读数 225

    本文在CentOS 6 64bit机器上演示Apache Flink环境的搭建以及运行测试样例。

下载Flink

1. 下载Flink: http://flink.apache.org/downloads.html

2. 解压下载文件, 当前最新版本是flink-1.2.1-bin-hadoop27-scala_2.11.tgz

tar zxvf flink-1.2.1-bin-hadoop27-scala_2.11.tgz
mv flink-1.2.1-bin-hadoop27-scala_2.11 flink    
cd flink

启动Flink本地集群

bin/start-local.sh

访问Flink控制台

访问http://localhost:8081/的Flink控制台,确保可以Flink Web Dashboard可以正确打开,如下图所示:

查看日志确保Flink启动成功,查看logs下的Flink****.log日志:

Registered TaskManager at localhost (akka://flink/user/taskmanager) as eb85ea8749850e84335a3b28bec4adce. Current number of registered hosts is 1. Current number of alive task slots is 1.

运行Word Count例子

打开一个终端,运行nc -l 9000,并打开第二个终端启动wordcount样例程序:

同时打开第三个终端,输入tail -f flink-work-jobmanager-**.out实时获取统计结果。此时回到第一个终端,尝试着键入一些英文单词,如下图所示:

回到结果监控终端,你会发现Flink已经可以实时地统计单词了!

关闭Flink

bin/stop-local.sh 

 

展开阅读全文
打赏
0
0 收藏
分享
加载中
更多评论
打赏
0 评论
0 收藏
0
分享
返回顶部
顶部