凌波微步Flink——Flink安装及简单实用
转载请注明出处:http://blog.csdn.net/dongdong9223/article/details/88819199
本文出自【我是干勾鱼的博客】
Ingredients:
Java:Java SE Development Kit 8u162(Oracle Java Archive),Linux下安装JDK并修改环境变量
Flink:flink-1.7.2-bin-scala_2.12.tgz(flink-1.7.2-bin-scala_2.12.tgz(mirror.bit.edu.cn/apache),Downloads,All Flink releases),Apache Flink® - Stateful Computations over Data Streams,Local Setup Tutorial,Building real-time dashboard applications with Apache Flink, Elasticsearch, and Kibana,Examples
1 下载
wget -c http://mirror.bit.edu.cn/apache/flink/flink-1.7.2/flink-1.7.2-bin-scala_2.12.tgz
2 解压缩
将文件放到目录:
/opt/flink/flink-1.7.2
然后解压缩:
tar -zxvf flink-1.7.2-bin-scala_2.12.tgz
3 启动
./bin/start-cluster.sh
浏览器中可以看到图形界面,访问地址:
http://IP:8081
界面如下:
4 监控日志
tail log/flink-*-standalonesession-*.log
5 示例
5.1 安装netcat
yum install -y nc
5.2 netcat启动本地服务
在终端上启动 netcat 获得输入流:
[root@shizhi002 flink-1.7.2]# nc -l 9000
hello world
这里输入了“hello world”这两个单词。
5.3 提交Flink程序
[root@shizhi002 flink-1.7.2]# ./bin/flink run examples/streaming/SocketWindowWordCount.jar --port 9000
Starting execution of program
5.4 查看统计结果
使用命令查看统计输出结果:
[root@shizhi002 flink-1.7.2]# tail -f log/flink-root-taskexecutor-0-shizhi002.out
world : 1
Have : 1
注意:如果想要看到某个大于1的计数的单词,则在5秒内反复键入这个单词就可以实现。
5.5 界面显示
5.6 关闭Flink
./bin/stop-cluster.sh
6 集群安装
对于集群的安装,可参考详细解析Flink集群的部署。
7 参考
Local Setup Tutorial
Examples
Building real-time dashboard applications with Apache Flink, Elasticsearch, and Kibana
Apache Flink 1.7 Documentation
Tumbling Windows vs Sliding Windows区别与联系
Flink 原理与实现:Window 机制
5分钟从零构建第一个 Flink 应用
Flink 零基础实战教程:如何计算实时热门商品
Flink在美团的实践与应用
详细解析Flink集群的部署
凌波微步Flink——Flink安装及简单实用相关推荐
- Logstash 安装及简单实用(同步MySql数据到Elasticsearch)
Logstash是一款轻量级的日志搜集处理框架,可以方便的把分散的.多样化的日志搜集起来,并进行自定义的处理,然后传输到指定的位置,比如某个服务器或者文件 Windows环境: 1.下载logstas ...
- u盘安装ubuntu_简单实用的ubuntu18.04安装
Linux诞生于1991年,Linus最初并没有想打造一个操作系统,然而Linus依然在为Linux而工作.现在Linux是世界上最大的网络协作项目,数十万人为Linux贡献代码. ubuntu 18 ...
- QGC地面站小白安装与简单实用
QGC二次开发 电脑:联想拯救者Lenovo R720,在电脑上安装虚拟机-->在虚拟机中安装UBuntu系统-->在Ubuntu中安装QGC以及Qt编译器. 1 安装VMware Wor ...
- Kubernetes(k8s)安装部署+简单实用
Kubernetes安装部署 Kubernetes是容器集群管理系统,是一个开源的平台,可以实现容器集群的自动化部署.自动扩缩容.维护等功能. 使用Kubernetes可以: 自动化容器的部署和复制 ...
- swoole 安装和简单实用
Swoole是:PHP语言的高性能网络通信框架,提供了PHP语言的异步多线程服务器,处理异步任务,异步TCP/UDP网络客户端,异步MySQL,数据库连接池,AsyncTask,消息队列,毫秒定时器, ...
- 一阳指Kibana——Kibana安装及简单实用
转载请注明出处:http://blog.csdn.net/dongdong9223/article/details/89214284 本文出自[我是干勾鱼的博客] Ingredients: Java: ...
- Robot Framework应用——Mac环境下Robot Framework的安装及简单实用
转载请注明出处:http://blog.csdn.net/dongdong9223/article/details/116591032 本文出自[我是干勾鱼的博客] 下载robotframework ...
- 凌波微步Flink——Flink的技术逻辑与编程步骤剖析
转载请注明出处:http://blog.csdn.net/dongdong9223/article/details/95459606 本文出自[我是干勾鱼的博客] Ingredients: Java: ...
- 凌波微步Flink——Flink API中的一些基础概念
转载请注明出处:http://blog.csdn.net/dongdong9223/article/details/95355619 本文出自[我是干勾鱼的博客] Ingredients: Java: ...
最新文章
- 从u盘设备启动arc-livecd
- mysql self join_mysql self join的实现--left join 和inner join
- FireFox火狐浏览器与IE兼容问题 - 透明滤镜 DIV滚动条
- docker概念:用Dockerfile生成Image
- 您应该对什么进行单元测试? –测试技术3
- Java命令:jstack — 获取线程dump信息
- html 地址 点击召唤高德,高德地图api 点聚合+海量点+点击事件(根据地区或坐标进行定位)...
- python 操作word docproprety_Python 的 类方法 静态方法 和 proprety
- [C++]Linux之C编程异常[true未定义解决方案]
- jQuery包裹节点用法完整示例
- 一个死去的网站shige.laiyo.com
- POJ 2983 Is the Information Reliable?(差分约束系统)
- el-dropdown 事件
- java中面向对象的例子_java面向对象九个经典例子程序
- 震网病毒这类“精确制导的网络导弹“与传统的网络攻击相比较,有哪些新的特点?
- HTML5网页文本内容
- com.netflix.client.ClientException: Load balancer does not have available server for client:XX 异常解决
- 哈夫曼编码器“数据结构课程设计”
- 题目:代码实现判断单链表是否有环
- 【cocos2dx】卡牌记忆游戏(2)——游戏场景