Flink集群部署
!(https://oscimg.oschina.net/oscnet/eeee0810cd304fd781092005350d834d.gif)!(https://oscimg.oschina.net/oscnet/69e44954e434413bb733e4968a970f43.png)大数据成神之路：点
Apache Flink漏洞复现
简介ApacheFlink是高效和分布式的通用数据处理平台，由Apache软件基金会开发的开源流处理框架，其核心是用Java和Scala编写的分布式流数据流引擎（简单来说，就是跟spark类似）。Flink具有监控API，可用于查询"正在运行的jobs"和"最近完成的jobs"的状态和统计信息。该监控API被用于Flink自
Flink SQL on Zeppelin
点击上方蓝色字体，选择“设为星标”回复”资源“获取更多资源!(https://oscimg.oschina.net/oscnet/ec2640aa4e5a46d09d9d528e7fe68f43.jpg)我们在之前的文章中详细介绍过Zepplin的来龙去脉，很多大厂基于Flink开发了自己的SQL开发平台。更多的公
Flink实战(八)
1概览1.1预定义的源和接收器Flink内置了一些基本数据源和接收器，并且始终可用。该预定义的数据源包括文件，目录和插socket，并从集合和迭代器摄取数据。该预定义的数据接收器支持写入文件和标准输入输出及socket。1.2绑定连接器连接器提供用于与各种第三方系统连接的代码。目
Apache Flink 介绍
本篇文章首发于我的微信公众号大数据技术和人工智能(https://www.oschina.net/action/GoToLink?urlhttps%3A%2F%2Fmp.weixin.qq.com%2Fs%3F__biz%3DMzU2Njg5Nzk0NQ%3D%3D%26mid%3D2247483660%26idx%3D1%26sn%3Decf01
Flink编程练习
\TOC\1.wordcount利用socket作为数据源，对输入的每行数据进行单词计数。计算频率为processtime的每10秒一次，结果输出到terminal。objectSocketWindowWordCount{defmain(args:ArrayString):U
Flink基于EventTime和WaterMark处理乱序事件和晚到的数据
在实际的业务中,我们经常会遇到数据迟到的情况,这个时候基于窗口进行计算的结果就不对了,Flink中watermark就是为了解决这个问题的,理解watermark之前,先来说一下flink中的三个与流数据相关的概念,ProcessTime、EventTime、IngestionTime,不然很难理解watermark是怎么回事.我们先来看一下官网给出的一
Call for Speaker！Flink Forward 全球在线会议议题征集 ing
4月2223日，全球首个Apache顶级项目在线会议FlinkForward完美落幕，FlinkForward中文精华版直播也吸引了国内2w人次开发者观看并参与互动。在此次大会中，除了久违的社区熟悉的面孔外，大佬们的分享和讲解想必也让大家对Flink社区的未来动向、最新应用更加清晰。但是！还不够！Flink1.11发