!(https://oscimg.oschina.net/oscnet/46b8a0ceb9054056a7f9887f580e6427.png)https://www.jianshu.com/p/dea467eb67e0TopNTopN是我们应用Flink进行业务开发时的常见场景，传统的DataS

最近这段时间一直在忙新集群迁移，上了最新的cdh6.3.0于是Flink提交遇到了许多的问题，还好有clouderaLicense有了原厂的帮助和社区的伙伴，问题解决起来快了不少。集群具体情况是CDH6.3.0Flink1.8.1,整个数据平台全部组件都上了kerberos和ldap因为要过认证，所以任务提交方法我们选择统一Oozie提交任务

一.引言：ApachFlink是全新的流处理系统，在SparkStraming的基础上添加了很多特性，主要在于其提供了基于时间和窗口计算的算子，并且支持有状态的存储和Checkpoint的重启机制，下面假设有多个温度传感器持续传输当前温度，Flink流处理需要每一段时间提供该时间段内的传感器平均温度。二.依赖支持项目是基

欢迎访问我的GitHubhttps://github.com/zq2599/blog\_demos(https://www.oschina.net/action/GoToLink?urlhttps%3A%2F%2Fgithub.com%2Fzq2599%2Fblog_demos)内容：所有原创文章分类汇总及配套源码，涉及Java、Doc

正文前先来一波福利推荐：福利一：百万年薪架构师视频，该视频可以学到很多东西，是本人花钱买的VIP课程，学习消化了一年，为了支持一下女朋友公众号也方便大家学习，共享给大家。福利二：毕业答辩以及工作上各种答辩，平时积累了不少精品PPT，现在共享给大家，大大小小加起来有几千套，总有适合你的一款，很多是网上是下载不到。

!(https://oscimg.oschina.net/oscnet/31a0748e049f466cb5a3eb5ac355307e.jpg)背景在电商、金融、银行、支付等涉及到金钱相关的领域，为了安全起见，一般都有对账的需求。比如，对于订单支付事件，用户通过某宝付款，虽然用户支付成功，但是用户支付完成后并

序    工作中用Flink做批量和流式处理有段时间了，感觉只看Flink文档是对FlinkProgramRuntime的细节描述不是很多，程序员还是看代码最简单和有效。所以想写点东西，记录一下，如果能对别人有所帮助，善莫大焉。    说一下我的工作，在一个项目里我们在FlinkSQL基础上构建了一个SQLEngine，

!(https://pic1.zhimg.com/80/v27d9d386c1ef04238abbbd67ee1ac7018_720w.jpg)剩喜漫天飞玉蝶，不嫌幽谷阻黄莺。2020年是不寻常的一年，Flink也在这一年迎来了新纪元。12月13–15号，2020FlinkForwardAsia（FFA）在春雪的召唤下顺利拉开

下载：BeginningPostgreSQLontheCloud:SimplifyingDatabaseasaServiceonCloudPlatforms(https://www.oschina.net/action/GoToLink?urlhttps%3A%2F%2Flink.jianshu.com%2F%3Ft%3Dhtt

点击上方蓝色字体，选择“设为星标”回复”资源“获取更多资源!(https://oscimg.oschina.net/oscnet/1dda42d7084840fca852642adfae864b.jpg)!(https://oscimg.oschina.net/oscnet/ddc63fc86f0e4799