Stella981 Stella981
3年前
Demo:基于 Flink SQL 构建流式应用
Flink1.10.0于近期刚发布,释放了许多令人激动的新特性。尤其是FlinkSQL模块,发展速度非常快,因此本文特意从实践的角度出发,带领大家一起探索使用FlinkSQL如何快速构建流式应用。本文将基于Kafka,MySQL,Elasticsearch,Kibana,使用FlinkSQL构建一个电商用户行为的实时分析应用
Stella981 Stella981
3年前
Flink SQL 1.11 on Zeppelin 平台化实践
简介: 鉴于有很多企业都无法配备专门的团队来解决FlinkSQL平台化的问题,那么到底有没有一个开源的、开箱即用的、功能相对完善的组件呢?答案就是本文的主角——ApacheZeppelin。作者:LittleMagic大数据领域SQL化开发的风潮方兴未艾(所谓"EverybodyknowsSQL"),Flink自然也不能“免
Stella981 Stella981
3年前
Scala之eq,equals,==的区别
一.简介  根据官方API(https://www.oschina.net/action/GoToLink?urlhttps%3A%2F%2Flink.jianshu.com%3Ft%3Dhttp%3A%2F%2Fwww.scalalang.org%2Fapi%2Fcurrent%2F%23scala.AnyRef)的定义:f
Stella981 Stella981
3年前
MongoDB(引擎)关于存储引擎 WiredTiger storage engine
WiredTiger(https://www.oschina.net/action/GoToLink?urlhttps%3A%2F%2Flink.jianshu.com%3Ft%3Dhttp%3A%2F%2Fwww.wiredtiger.com%2F)在3.2版本成为mongodb的默认存储引擎。所以这里讲的就是WiredTiger了。Doc
Stella981 Stella981
3年前
ScreenToGif 使用教程
ScreenToGif 使用教程ScreenToGif是个强大的Gif录制/剪辑工具。其使用指南译文如下:第一部分:录制(https://www.oschina.net/action/GoToLink?urlhttps%3A%2F%2Flink.jianshu.com%3Ft%3Dhttp%253A%25
Stella981 Stella981
3年前
Koa2实战练手(一)
Koa(https://www.oschina.net/action/GoToLink?urlhttps%3A%2F%2Flink.jianshu.com%3Ft%3Dhttp%3A%2F%2Fkoajs.com%2F)是下一代的Node.js的Web框架。由Express(https://www.oschina.net/action/
Stella981 Stella981
3年前
Flink 自定义触发器实现带超时时间的 CountWindow
点击上方蓝色字体,选择“设为星标”回复”资源“获取更多资源!(https://oscimg.oschina.net/oscnet/b125d6e943e7d4cb6c52ad99ee17fc16dbe.jpg)Flink的window有两个基本款,TimeWindow和CountWindow。TimeWindo
flinkcdc中checkpoint不成功问题排查
本文分享自天翼云开发者社区《》,作者:徐东使用flink1.16和flinkcdc3.0进行数据接入,采用standalone模式。运行一段时间后checkpoint开始失败,但日志中没有报错信息。因savepoint和checkpoint机制一致,使用手