1.需求 在某些情況下，我們需要保證flink在消費kafka時，對于某些具有相同標(biāo)識的消息，要保證其順序性。比如說具有相同uuid的用戶行為消...
投稿
收錄了9篇文章 · 4人關(guān)注
-
Flink消費Kafka如何保證相同標(biāo)識消息的有序性
-
分布式Snapshot和Flink Checkpointing簡介
摘要：最近在學(xué)習(xí)Flink的Fault Tolerance，了解到Flink在Chandy Lamport Algorithm的基礎(chǔ)上擴展實現(xiàn)了...
-
一文讓你徹底了解大數(shù)據(jù)實時計算引擎 Flink
前言 在上一篇文章 你公司到底需不需要引入實時計算引擎？ 中我講解了日常中常見的實時需求，然后分析了這些需求的實現(xiàn)方式，接著對比了實時計算和離線...
-
Flink通信機制flink內(nèi)部通信機制 Operator間的數(shù)據(jù)傳遞本地線程數(shù)據(jù)傳遞遠(yuǎn)程線程數(shù)據(jù)傳遞同一線程的Operator數(shù)據(jù)傳遞 Buffer讀寫B(tài)uff...
-
Flink 原理與實現(xiàn)：內(nèi)存管理如今，大數(shù)據(jù)領(lǐng)域的開源框架（Hadoop，Spark，Storm）都使用的 JVM，當(dāng)然也包括 Flink?；?JVM 的數(shù)據(jù)分析引擎都需要面...
-
Apache Flink源碼解析 （七）Flink RPC的底層實現(xiàn)
Prerequisites Flink的RPC服務(wù)是基于Akka Remote實現(xiàn)的。一個簡單的Akka Remoting ActorSyste...
-
Flink 的Window 操作
Flink的 Window 操作 Window是無限數(shù)據(jù)流處理的核心，Window將一個無限的stream拆分成有限大小的”buckets”桶，...
-
Spring Boot 2 官方指導(dǎo)手冊譯文
入門 介紹 Spring Boot Spring Boot 使您可以輕松地創(chuàng)建獨立的、生產(chǎn)級的基于 Spring 的應(yīng)用程序，您可以運行這些應(yīng)用...
-
Apache Flink源碼解析 （六）執(zhí)行計劃生成之StreamGraph-上半篇: 通過DataStream API概述 根據(jù)上一篇文章 DataStream API 可以得知每一個方法生成的Transformation和實際運行中對Task的影響。事實上從T...
{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://www.itdecent.cn/c/63535214f7b9?utm_campaign=maleskine&utm_content=collection&utm_medium=reader_share&utm_source=weibo','頁面編碼gb2312|utf-8默認(rèn)gb2312'));){kind=link}