發(fā)簡(jiǎn)信
IP屬地：上海
-
Flink timer注冊(cè)與watermark觸發(fā)[轉(zhuǎn)載自網(wǎng)易云音樂(lè)實(shí)時(shí)計(jì)算平臺(tái)經(jīng)典實(shí)踐知乎專欄]經(jīng)作者magina本人同意，轉(zhuǎn)載自原文在flink中無(wú)論是windowOperator還是KeyedProcessOperator都持有Inte...
-
Flink任務(wù)物理內(nèi)存溢出問(wèn)題定位問(wèn)題現(xiàn)象 一個(gè)使用10秒滾動(dòng)窗口的任務(wù)在平穩(wěn)運(yùn)行一段時(shí)間之后出現(xiàn)了頻繁的重啟。在TaskManager日志中能看到以下文本： 原因定位 首先可以...
-
Apache Flink源碼解析 （八）Flink的HighAvailabilityServices概述 Flink內(nèi)部有一些服務(wù)是JobMaster和TaskExecutor共用的。如HighAvailabilityServices, Rpc...
-
有狀態(tài)的流處理系統(tǒng)的彈性伸縮(Elastic Scaling)前言 看到一篇14年的關(guān)于流處理系統(tǒng)的彈性縮擴(kuò)容的論文Elastic Scaling for Data Stream Processing，覺(jué)得...
-
Apache Flink源碼解析 （七）Flink RPC的底層實(shí)現(xiàn)
Prerequisites Flink的RPC服務(wù)是基于Akka Remote實(shí)現(xiàn)的。一個(gè)簡(jiǎn)單的Akka Remoting ActorSyste...
-
關(guān)于流數(shù)據(jù)上的事務(wù)操作
概述 最近Flink母公司Data Artisans發(fā)布了一篇博客關(guān)于一個(gè)新的組件Streaming Ledger，給出了流數(shù)據(jù)的事務(wù)解決方案（...
-
Apache Flink源碼解析 （六）執(zhí)行計(jì)劃生成之StreamGraph-上半篇: 通過(guò)DataStream API概述 根據(jù)上一篇文章 DataStream API 可以得知每一個(gè)方法生成的Transformation和實(shí)際運(yùn)行中對(duì)Task的影響。事實(shí)上從T...
-
Apache Flink源碼解析 （五）DataStream API概述 這篇文章是但不僅僅是官方文檔的中文翻譯，還有里面每一個(gè)方法對(duì)應(yīng)的Transformation和運(yùn)行時(shí)對(duì)Task的影響。 Prerequis...
-
Leetcode算法解析101+
<center>#104 Maximum Depth of Binary Tree</center> link Description:Give...
個(gè)人介紹
Apache Flink Contributor，巴西鐵桿，巴薩死忠，硬搖粉，分布式系統(tǒng)愛(ài)好者，github: https://github.com/Clarkkkkk