發(fā)簡信
IP屬地：浙江
-
Flink內(nèi)存管理前言 參考 : <Flink內(nèi)核原理與實(shí)踐> 1. 一個(gè)java對(duì)象內(nèi)存大小 java所有數(shù)據(jù)類型對(duì)應(yīng)的字節(jié)大小 類型大小(byte)說明Lon...
-
Flink數(shù)據(jù)傳輸源碼及原理Flink數(shù)據(jù)交換源碼及其原理 前言 對(duì)于里面內(nèi)容我們需要一定的netty只是,在涉及網(wǎng)絡(luò)交互的時(shí)候是基于netty的,所以不了解netty可能...
-
Flink-cdc源碼剖析Flink cdc源碼 前言 flink-cdc源碼地址 : https://github.com/ververica/flink-cdc-co...
-
Flink-1.10 源碼筆記 算子解析->MapOperator
Flink 1.10 源碼 -- Map 導(dǎo)讀1.map是什么2.map的源碼和調(diào)用過程3.transition方法的源碼4.通過底層接口實(shí)現(xiàn)m...
-
記錄Flink1.9線上checkpoint失敗的問題最新在線上更新了代碼之后導(dǎo)致了任務(wù)在消費(fèi)kafka數(shù)據(jù)的時(shí)候,突然就不消費(fèi)數(shù)據(jù)了,發(fā)現(xiàn)原因在公司的可視化界面中,看不到數(shù)據(jù)的更新,進(jìn)入flink...
-
Clickhouse集群搭建
clickhouse官網(wǎng),也會(huì)有集群搭建的內(nèi)容[https://clickhouse.tech/docs/en/] 搭建前的準(zhǔn)備 配置好防火墻以...
-
Hbase - Compaction合并機(jī)制Hbase - Compaction 當(dāng)MemStore達(dá)到給定的大小時(shí)(hbase.hregion.memstore.flush.size),...
-
Spark 連接kafka兩種方式及區(qū)別(direct和receiver)Kafka Direct 跟Receiver方式的區(qū)別 Receiver Receiver是使用Kafka的 High-Level Consum...
-
Hadoop - HDFSHDFS 分布式文件系統(tǒng) Hadoop -YARNHadoop -MapReduce 導(dǎo)讀1.HDFS是什么2.HDFS架構(gòu)及組件功能介紹3....