太喜欢这种博文了,干货满,思路清晰,再也不怕flink源码了😋
Flink 源码之TaskManager启动流程Flink源码分析系列文档目录 请点击:Flink 源码分析系列文档目录[https://www.jianshu.com/p/d4a372809e3d] 启动脚本分析 Tas...
太喜欢这种博文了,干货满,思路清晰,再也不怕flink源码了😋
Flink 源码之TaskManager启动流程Flink源码分析系列文档目录 请点击:Flink 源码分析系列文档目录[https://www.jianshu.com/p/d4a372809e3d] 启动脚本分析 Tas...
Flink源码分析系列文档目录 请点击:Flink 源码分析系列文档目录[https://www.jianshu.com/p/d4a372809e3d] 启动脚本分析 Tas...
Disruptor核心源码分析 说来惭愧,Log4j2的异步日志已经用了将近2年时间了。但是每次想看Disruptor源码的时候,总是没能坚持下去。这次通过一次生产环境的故障...
写的很好,收获颇丰,期待能读到作者更多精彩的文章👍
Disruptor核心源码分析Disruptor核心源码分析 说来惭愧,Log4j2的异步日志已经用了将近2年时间了。但是每次想看Disruptor源码的时候,总是没能坚持下去。这次通过一次生产环境的故障...
HBase的源码: 1、集群启动master启动regionsever启动2、put 插入数据源码分析delete3、get 查询数据源码分析scan4、三个重要的行为:fl...
1.Reactor模式介绍 Reactor模式是事件驱动模型,有一个或多个并发输入源,有一个Service Handler,有多个Request Handlers;这个Ser...
背景 MapReduce不能满足大数据快速实时adhoc查询计算的性能要求,Facebook2012年开发,2013年开源 是什么 基于内存的并行计算,Facebook推出的...
干活满满,解开了不少疑惑。希望再接再厉,技术蒸蒸日上,同时也能产出更多这样高品质的文章。
JavaNIO-MappedByteBuffer内核空间与用户空间 Kernel space 是 Linux 内核的运行空间,User space 是用户程序的运行空间。为了安全,它们是隔离的,即使用户的程序崩溃了,内核也...
流程 流程讲解 在我们通过代码send消息之后,这条消息就会发往拦截器Interceptor Interceptor会对数据做处理加解密/脱敏过滤不满足条件的数据(ip白名单...
一、What 一个主从架构的分布式框架 给分布式框架提供协调服务(service) 作用 提供简版文件系统来存储数据 维护和监控存储的数据状态变化,通过监控数据状态变化达到基...
写得挺棒的,加油!
java程序员,不懂JIT,你写的代码慢死了努力做程序员中的标题党,这个文章的副标题 面向JIT编程-方法内联 JIT的全称是Just in time compilation,中文称之为即时编译。JIT是JVM最强大的...
努力做程序员中的标题党,这个文章的副标题 面向JIT编程-方法内联 JIT的全称是Just in time compilation,中文称之为即时编译。JIT是JVM最强大的...
背景 yarn默认使用的是最简单的FIFO调度器,即一个default队列,所有用户共享,分配资源也是先到先得,没有优先级之分。有时一两个任务就把资源全占了,其他任务吃不到资...
一、 更改目录操作 该操作基本只和NameNode进行交互 rename/mkdir等操作 NameNode在目录树数据结构上对应位置创建新的目录节点并持久化到日志中。 de...