1.需求 在某些情况下，我们需要保证flink在消费kafka时，对于某些具有相同标识的消息，要保证其顺序性。比如说具有相同uuid的用户行为消...
投稿
收录了9篇文章 · 4人关注
-
Flink消费Kafka如何保证相同标识消息的有序性
-
分布式Snapshot和Flink Checkpointing简介
摘要：最近在学习Flink的Fault Tolerance，了解到Flink在Chandy Lamport Algorithm的基础上扩展实现了...
-
一文让你彻底了解大数据实时计算引擎 Flink
前言 在上一篇文章 你公司到底需不需要引入实时计算引擎？ 中我讲解了日常中常见的实时需求，然后分析了这些需求的实现方式，接着对比了实时计算和离线...
-
Flink通信机制flink内部通信机制 Operator间的数据传递本地线程数据传递远程线程数据传递同一线程的Operator数据传递 Buffer读写Buff...
-
Flink 原理与实现：内存管理如今，大数据领域的开源框架（Hadoop，Spark，Storm）都使用的 JVM，当然也包括 Flink。基于 JVM 的数据分析引擎都需要面...
-
Apache Flink源码解析 （七）Flink RPC的底层实现
Prerequisites Flink的RPC服务是基于Akka Remote实现的。一个简单的Akka Remoting ActorSyste...
-
Flink 的Window 操作
Flink的 Window 操作 Window是无限数据流处理的核心，Window将一个无限的stream拆分成有限大小的”buckets”桶，...
-
Spring Boot 2 官方指导手册译文
入门 介绍 Spring Boot Spring Boot 使您可以轻松地创建独立的、生产级的基于 Spring 的应用程序，您可以运行这些应用...
-
Apache Flink源码解析 （六）执行计划生成之StreamGraph-上半篇: 通过DataStream API概述 根据上一篇文章 DataStream API 可以得知每一个方法生成的Transformation和实际运行中对Task的影响。事实上从T...
专题公告
flink相关内容
{var%20f='http://v.t.sina.com.cn/share/share.php?appkey=1881139527',u=z||d.location,p=['&url=',e(u),'&title=',e(t||d.title),'&source=',e(r),'&sourceUrl=',e(l),'&content=',c||'gb2312','&pic=',e(p||'')].join('');function%20a(){if(!window.open([f,p].join(''),'mb',['toolbar=0,status=0,resizable=1,width=440,height=430,left=',(s.width-440)/2,',top=',(s.height-430)/2].join('')))u.href=[f,p].join('');};if(/Firefox/.test(navigator.userAgent))setTimeout(a,0);else%20a();})(screen,document,encodeURIComponent,'','','https://upload.jianshu.io/collections/images/1659435/spark%E7%94%9F%E6%80%81.jpg', '推荐专题《flink》（ 分享自 @简书 ）','http://39.103.169.235/c/63535214f7b9?utm_campaign=maleskine&utm_content=collection&utm_medium=reader_share&utm_source=weibo','页面编码gb2312|utf-8默认gb2312'));){kind=link}