前言 如果要列举Flink SQL新手有可能犯的错误，笔者认为其中之一就是忘记设置空闲状态保留时间导致状态爆炸。2021年的第一篇技术文，时间很紧张，聊聊这个简单的话题吧。 ...
发简信
IP属地：广东
-
Flink SQL空闲状态保留时间（idle state retention time）实现原理 -
数据分析实践 | flink | window窗口篇要弄懂flink全部的工作机制其实是一件比较麻烦的事情，零碎的概念太多，对于第一次接触flink的我也算是个挑战。 整体感受就是--看官方文档的过程就像在做高中的阅读理解：）...
-
Flink Window触发机制
1. Flink的Window类型 Flink基本分有3种window类型：CountWindow，TimeWindow和SessionWindow。其中，CountWind...
-
Elasticsearch的底层模块深入解析之shard allocation
1、shard allocation的介绍 两种node：master node，data node master node的一个很重要的功能，比如说，你现在创建了一个索引，...
-
flink的内存管理在大数据面前，JVM的内存结构和GC机制往往会成为掣肘 1. 对象开销：在HotSpot中，每个对象占用的内存空间必须是8的倍数。这就导致每个对象占据的内存空间包含三部分：头...
-
spark-streaming-kafka之createDirectStream模式
完整工程用例 最近一直在用directstream方式消费kafka中的数据，特此总结，整个代码工程分为三个部分一. 完整工程代码如下(某些地方特意做了说明, 这个代码的部...
-
2015 Bossie评选：最佳开源大数据工具//2015 Bossie评选：最佳开源大数据工具-CSDN.NEThttp://www.csdn.net/article/2015-10-20/2825959ddply 摘...
-
Apache Ranger安装配置以及和LDAP集成
导语 Ranger是Hadoop平台的集中式安全管理框架，能够为hadoop平台组件提供细粒度的访问控制。通过Ranger, Hadoop管理员能够轻松地管理各种安全策略，包...
-
心有猛虎，细嗅蔷薇--10本电子好书推荐命运对于我们并无所谓好坏，它只供给我们好坏的原料和种子。这些原料和种子会随时根据我们每个个体的精神特点发生变化，因为我们每个人才是自己幸与不幸的唯一主宰。盐放入一杯水中，会咸...
