Flink实战教程
目录：自定义函数单个eval方法多个eval方法不固定参数通过注解指定返回类型注册函数构造数据源查询leftjoinjoin多种
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整合Oozie Shell Action 提交任务带Kerberos认证
最近这段时间一直在忙新集群迁移，上了最新的cdh6.3.0于是Flink提交遇到了许多的问题，还好有clouderaLicense有了原厂的帮助和社区的伙伴，问题解决起来快了不少。集群具体情况是CDH6.3.0Flink1.8.1,整个数据平台全部组件都上了kerberos和ldap因为要过认证，所以任务提交方法我们选择统一Oozie提交任务
Flink架构，源码及debug
序 工作中用Flink做批量和流式处理有段时间了，感觉只看Flink文档是对FlinkProgramRuntime的细节描述不是很多，程序员还是看代码最简单和有效。所以想写点东西，记录一下，如果能对别人有所帮助，善莫大焉。 说一下我的工作，在一个项目里我们在FlinkSQL基础上构建了一个SQLEngine，
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发