發(fā)簡(jiǎn)信
IP屬地：河南
-
Flink Checkpoint變遷與實(shí)踐一、歷史變遷 在Flink 1.0.0時(shí)期 提供了RocksDB的支持，這個(gè)版本之前所有的狀態(tài)都只能存在進(jìn)程的內(nèi)存里面，這個(gè)內(nèi)存總有存不下的一天...
-
Flink異常指南
1、Checkpoint失?。篊heckpoint expired before completing 原因是因?yàn)閏heckpointConf....
-
初識(shí)Flink WaterMarker
前言 對(duì)于流計(jì)算來(lái)說(shuō)，最核心的概念就是無(wú)窮數(shù)據(jù)集，而用來(lái)處理無(wú)窮數(shù)據(jù)集的計(jì)算就可以稱為流計(jì)算。面對(duì)無(wú)窮數(shù)據(jù)集，有多種多樣的處理方式，但是大致上可...
-
Jobs and SchedulingScheduling 1、Flink的Execution resources是通過(guò)Task Slots定義的。每個(gè)TaskManager 都有一...
-
MemorySegment
概述 就像我們所知道的，F(xiàn)link采用了自己管理內(nèi)存的方式，或者說(shuō)積極的內(nèi)存管理，而MemorySegment就是Flink實(shí)現(xiàn)自己內(nèi)存管理的核...
-
Data exchange between tasks基本原則 https://cwiki.apache.org/confluence/display/FLINK/Data+exchange+bet...
-
Rescaling Stateful Applications in Production一、概述 數(shù)據(jù)局部性是Flink中的一個(gè)關(guān)鍵原則，并且強(qiáng)烈影響狀態(tài)的存儲(chǔ)和訪問(wèn)方式。Flink中的狀態(tài)都是Local State。Why loc...
-
Actor system(Akka) in Flink一、概述 Flink's distributed execution consists of two important processes, ...
-
Physical Partitioning in Flink Streaming一、Physical partitioning 在一個(gè)transformation之后，F(xiàn)link也提供了底層API以允許用戶在必要時(shí)精確控制流...