转载请注明出处: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安装及简单实用相关推荐

  1. Logstash 安装及简单实用(同步MySql数据到Elasticsearch)

    Logstash是一款轻量级的日志搜集处理框架,可以方便的把分散的.多样化的日志搜集起来,并进行自定义的处理,然后传输到指定的位置,比如某个服务器或者文件 Windows环境: 1.下载logstas ...

  2. u盘安装ubuntu_简单实用的ubuntu18.04安装

    Linux诞生于1991年,Linus最初并没有想打造一个操作系统,然而Linus依然在为Linux而工作.现在Linux是世界上最大的网络协作项目,数十万人为Linux贡献代码. ubuntu 18 ...

  3. QGC地面站小白安装与简单实用

    QGC二次开发 电脑:联想拯救者Lenovo R720,在电脑上安装虚拟机-->在虚拟机中安装UBuntu系统-->在Ubuntu中安装QGC以及Qt编译器. 1 安装VMware Wor ...

  4. Kubernetes(k8s)安装部署+简单实用

    Kubernetes安装部署 Kubernetes是容器集群管理系统,是一个开源的平台,可以实现容器集群的自动化部署.自动扩缩容.维护等功能. 使用Kubernetes可以: 自动化容器的部署和复制 ...

  5. swoole 安装和简单实用

    Swoole是:PHP语言的高性能网络通信框架,提供了PHP语言的异步多线程服务器,处理异步任务,异步TCP/UDP网络客户端,异步MySQL,数据库连接池,AsyncTask,消息队列,毫秒定时器, ...

  6. 一阳指Kibana——Kibana安装及简单实用

    转载请注明出处:http://blog.csdn.net/dongdong9223/article/details/89214284 本文出自[我是干勾鱼的博客] Ingredients: Java: ...

  7. Robot Framework应用——Mac环境下Robot Framework的安装及简单实用

    转载请注明出处:http://blog.csdn.net/dongdong9223/article/details/116591032 本文出自[我是干勾鱼的博客] 下载robotframework ...

  8. 凌波微步Flink——Flink的技术逻辑与编程步骤剖析

    转载请注明出处:http://blog.csdn.net/dongdong9223/article/details/95459606 本文出自[我是干勾鱼的博客] Ingredients: Java: ...

  9. 凌波微步Flink——Flink API中的一些基础概念

    转载请注明出处:http://blog.csdn.net/dongdong9223/article/details/95355619 本文出自[我是干勾鱼的博客] Ingredients: Java: ...

最新文章

  1. 从u盘设备启动arc-livecd
  2. mysql self join_mysql self join的实现--left join 和inner join
  3. FireFox火狐浏览器与IE兼容问题 - 透明滤镜 DIV滚动条
  4. docker概念:用Dockerfile生成Image
  5. 您应该对什么进行单元测试? –测试技术3
  6. Java命令:jstack — 获取线程dump信息
  7. html 地址 点击召唤高德,高德地图api 点聚合+海量点+点击事件(根据地区或坐标进行定位)...
  8. python 操作word docproprety_Python 的 类方法 静态方法 和 proprety
  9. [C++]Linux之C编程异常[true未定义解决方案]
  10. jQuery包裹节点用法完整示例
  11. 一个死去的网站shige.laiyo.com
  12. POJ 2983 Is the Information Reliable?(差分约束系统)
  13. el-dropdown 事件
  14. java中面向对象的例子_java面向对象九个经典例子程序
  15. 震网病毒这类“精确制导的网络导弹“与传统的网络攻击相比较,有哪些新的特点?
  16. HTML5网页文本内容
  17. com.netflix.client.ClientException: Load balancer does not have available server for client:XX 异常解决
  18. 哈夫曼编码器“数据结构课程设计”
  19. 题目:代码实现判断单链表是否有环
  20. 【cocos2dx】卡牌记忆游戏(2)——游戏场景

热门文章

  1. 姓名缘分查询易语言代码
  2. 数组 去除重复元素 的三种方法
  3. XGB LGB GBDT 比较
  4. 蝴蝶定理及其对高中解析几何的启示
  5. 8080端口被占用,cmd关闭8080端口命令
  6. linux:redhat:bash: setenforce: command not found
  7. 8. vma操作概述
  8. 阻塞IO与非阻塞IO的区别
  9. java 文本差异对比高亮工具
  10. C/C++后台开发与测试开发面经2018年3-4月