鐺鐺鐺clark

鐺鐺鐺clark

IP屬地：上海

Flink timer注冊與watermark觸發(fā)[轉(zhuǎn)載自網(wǎng)易云音樂實時計算平臺經(jīng)典實踐知乎專欄]
經(jīng)作者magina本人同意蔓涧，轉(zhuǎn)載自原文在flink中無論是windowOperator還是KeyedProcessOperator都持有Inte...

0.2 1960 0 2
Flink任務(wù)物理內(nèi)存溢出問題定位
問題現(xiàn)象一個使用10秒滾動窗口的任務(wù)在平穩(wěn)運(yùn)行一段時間之后出現(xiàn)了頻繁的重啟谁帕。在TaskManager日志中能看到以下文本：原因定位首先可以...

0.9 14898 3 8

Apache Flink源碼解析（八）Flink的HighAvailabilityServices
概述 Flink內(nèi)部有一些服務(wù)是JobMaster和TaskExecutor共用的惶凝。如HighAvailabilityServices, Rpc...

0.1 2782 0 3
有狀態(tài)的流處理系統(tǒng)的彈性伸縮(Elastic Scaling)
前言看到一篇14年的關(guān)于流處理系統(tǒng)的彈性縮擴(kuò)容的論文Elastic Scaling for Data Stream Processing吼虎，覺得...

0.9 1578 1 8
Apache Flink源碼解析（七）Flink RPC的底層實現(xiàn)
Prerequisites Flink的RPC服務(wù)是基于Akka Remote實現(xiàn)的。一個簡單的Akka Remoting ActorSyste...

1.3 5637 1 16
關(guān)于流數(shù)據(jù)上的事務(wù)操作
概述最近Flink母公司Data Artisans發(fā)布了一篇博客關(guān)于一個新的組件Streaming Ledger苍鲜，給出了流數(shù)據(jù)的事務(wù)解決方案（...

0.1 1199 2 3
Apache Flink源碼解析（六）執(zhí)行計劃生成之StreamGraph-上半篇: 通過DataStream API
概述根據(jù)上一篇文章 DataStream API 可以得知每一個方法生成的Transformation和實際運(yùn)行中對Task的影響思灰。事實上從T...

0.4 2809 0 11 1

Apache Flink源碼解析（五）DataStream API
概述這篇文章是但不僅僅是官方文檔的中文翻譯，還有里面每一個方法對應(yīng)的Transformation和運(yùn)行時對Task的影響混滔。 Prerequis...

0.2 9992 0 12 1
Leetcode算法解析101+
<center>#104 Maximum Depth of Binary Tree</center> link Description:Give...

1568 0 0