文档章节

Apache Flink Quickstart

huxihx
 huxihx
发布于 2017/05/22 14:54
字数 274
阅读 193
收藏 0

    本文在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 

 

© 著作权归作者所有

下一篇: Apache Flink介绍
huxihx
粉丝 1
博文 18
码字总数 30674
作品 0
东城
程序员
私信 提问
Apache Flink 1.7.1 发布,开源流处理框架

Apache Flink 1.7.1 已发布,此版本包括27项修复及针对 Flink 1.7.0 的小改进。建议所有用户升级。Apache Flink 是一个开源的流处理框架,应用于分布式、高性能、始终可用的、准确的数据流应...

王练
2018/12/23
1K
0
Apache Flink®生态所面临的机遇与挑战

作者:简锋 引言 在谈生态之前,我们来聊聊什么是生态。生态是指在某个特定领域,以某个组件为核心衍生出来其他多个组件,这些组件可以间接或者直接用到这个核心组件,然后辅助这个核心组件共...

Ververica
05/05
0
0
Flink Quickstart

Quickstart# Get a Flink example program up and running in a few simple steps. Setup: Download and Start Flink# Flink runs on Linux, Mac OS X, and Windows. To be able to run Flin......

群星纪元
03/19
76
0
Flink 1.7 文档翻译活动期待大家的参与 | ApacheCN

参与方式:github.com/apachecn/fl… 整体进度:github.com/apachecn/fl… 项目仓库:github.com/apachecn/fl… 贡献指南 请您勇敢地去翻译和改进翻译。虽然我们追求卓越,但我们并不要求您做...

ApacheCN_飞龙
02/16
0
0
Apache Flink China Meetup·深圳站 - 计算之美,何止于快

就在去年8月26日,Flink China主办了Flink深圳站线下主题沙龙,当时很多人的反应是:Flink是什么? Flink真的这么牛?这和我(业务)有啥关系? 因为不了解Flink,一些在深圳的技术人没有报名...

Flink_China
03/29
118
0

没有更多内容

加载失败,请刷新页面

加载更多

maven 环境隔离

解决问题 即 在 resource 文件夹下面 ,新增对应的资源配置文件夹,对应 开发,测试,生产的不同的配置内容 <resources> <resource> <directory>src/main/resources.${deplo......

之渊
今天
8
0
Linux创建yum仓库

第一步、搞定自己的光盘 #创建文件夹 mkdir -p /media/cdrom #挂载光盘 mount /dev/cdrom /media/cdrom #编辑配置文件使其永久生效 vim /etc/fstab 第二步,编辑yun源 vim /ect yum.repos.d...

究极小怪兽zzz
今天
6
0
jar 更新部分文件

C:\Program Files (x86)\Java\jdk1.8.0_102\bin>jar -hIllegal option: hUsage: jar {ctxui}[vfmn0PMe] [jar-file] [manifest-file] [entry-point] [-C dir] files ...Options: -c c......

圣洁之子
今天
9
0
OSChina 周六乱弹 —— 感谢女装红薯开办了这个网站

Osc乱弹歌单(2019)请戳(这里) 【今日歌曲】 @胖达panda:分享歌词: 我有一只小毛驴我从来也不骑,有一天我心血来潮骑着去赶集,我手里拿着小皮鞭我心里正得意,不知怎么哗啦啦,我摔了一...

小小编辑
今天
2.7K
13
DDD(四)

1,引言 软件开发者大多趋向于将关注点放在数据上,而不是领域上。这对于刚入门的DDD的新手而言也是如此。以我目前的思考方式,数据库依然占据主要的地位。开发一个功能,首先我就会考虑我会...

MrYuZixian
昨天
7
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部