发简信
IP属地：江苏
-
-
Flink消费Kafka如何保证相同标识消息的有序性
1.需求 在某些情况下，我们需要保证flink在消费kafka时，对于某些具有相同标识的消息，要保证其顺序性。比如说具有相同uuid的用户行为消息，要保证其消息的顺序性，这样...
-
-
分布式Snapshot和Flink Checkpointing简介
摘要：最近在学习Flink的Fault Tolerance，了解到Flink在Chandy Lamport Algorithm的基础上扩展实现了一套分布式Checkpoint...
-
-
-
-
Flink通信机制flink内部通信机制 Operator间的数据传递本地线程数据传递远程线程数据传递同一线程的Operator数据传递 Buffer读写Buffer读取Buffer写入 内存...
-
我曾以为<br>黎明之后太阳就会升起<br>就会有光<br>后来才知道<br>原来黑夜和黎明之间<br>还有一个时刻叫破晓<br>破晓之后<br>新的一天才正式开始。。。
-
高并发下接口的幂等性设计推荐微博：https://www.cnblogs.com/huaixiaonian/p/9577567.html 1. 接口调用存在的问题 现如今我们的系统大多拆分为分布式...
-
-
Flink 原理与实现：内存管理如今，大数据领域的开源框架（Hadoop，Spark，Storm）都使用的 JVM，当然也包括 Flink。基于 JVM 的数据分析引擎都需要面对将大量数据存到内存中，这就不...
-
-
Flink源码解析之Job提交(下)上一篇文章我们讲解了通过命令行将一个Job提交到TaskManager的整体过程，但是我们中间忽略了一些细节，比如Job提交到集群的哪些节点，JobGraph是什么，它是如何...
-
-
Spark--数据倾斜解决方案数据倾斜分为两大类：聚合倾斜和join倾斜，针对不同的倾斜类型采用不同解决方案 数据倾斜解决方案上分为：缓解数据倾斜和彻底解决数据倾斜 1.数据倾斜表现形势 导致数据倾斜的算...
