发简信
IP属地：上海
-
Flink内存管理前言 参考 : <Flink内核原理与实践> 1. 一个java对象内存大小 java所有数据类型对应的字节大小 类型大小(byte)说明Lon...
-
Flink数据传输源码及原理Flink数据交换源码及其原理 前言 对于里面内容我们需要一定的netty只是,在涉及网络交互的时候是基于netty的,所以不了解netty可能...
-
Flink-cdc源码剖析Flink cdc源码 前言 flink-cdc源码地址 : https://github.com/ververica/flink-cdc-co...
-
Flink-1.10 源码笔记 算子解析->MapOperator
Flink 1.10 源码 -- Map 导读1.map是什么2.map的源码和调用过程3.transition方法的源码4.通过底层接口实现m...
-
记录Flink1.9线上checkpoint失败的问题最新在线上更新了代码之后导致了任务在消费kafka数据的时候,突然就不消费数据了,发现原因在公司的可视化界面中,看不到数据的更新,进入flink...
-
Clickhouse集群搭建
clickhouse官网,也会有集群搭建的内容[https://clickhouse.tech/docs/en/] 搭建前的准备 配置好防火墙以...
-
Hbase - Compaction合并机制Hbase - Compaction 当MemStore达到给定的大小时(hbase.hregion.memstore.flush.size),...
-
Spark 连接kafka两种方式及区别(direct和receiver)Kafka Direct 跟Receiver方式的区别 Receiver Receiver是使用Kafka的 High-Level Consum...
-
Hadoop - HDFSHDFS 分布式文件系统 Hadoop -YARNHadoop -MapReduce 导读1.HDFS是什么2.HDFS架构及组件功能介绍3....