归档 | Matt's Blog

2020

2020/10/31Stateful Serverless 背后的 Flink StateFun 内部机制实现【译】
2020/10/25Flink StateFun 2.0 浅谈
2020/08/02Kubenetes 之新手入门篇
2020/04/16浅谈 CPU 分支预测技术
2020/03/20Flink 基于 MailBox 实现的 StreamTask 线程模型
2020/03/15Flink TaskManager 详解（一）

2019

2019/12/27Flink JobManager 详解
2019/12/23Flink Master 详解
2019/12/20Flink 如何生成 ExecutionGraph
2019/12/09Flink Streaming 作业如何转化为 JobGraph
2019/12/08Flink DataStream API 概述及作业如何转换为 StreamGraph
2019/11/23Apache Flink 初探
2019/10/27Paper 阅读: Distributed Snapshots: Determining Global States of Distributed Systems
2019/10/20Paper 阅读: Lightweight Asynchronous Snapshots for Distributed Dataflow
2019/10/19Paper 阅读: Real-Time Machine Learning: The Missing Pieces
2019/03/17Apache Calcite 优化器详解（二）
2019/03/07Apache Calcite 处理流程详解（一）
2019/01/28BookKeeper 原理浅谈

2018

2018/11/21如何高效学习
2018/11/04Kafka Exactly-Once 之事务性实现
2018/10/24Kafka 事务性之幂等性实现
2018/10/19BookKeeper 集群搭建及使用
2018/09/01YARN 架构学习总结
2018/08/01如何学习开源项目
2018/07/28JVM 之 ParNew 和 CMS 日志分析
2018/07/15HDFS 架构学习总结
2018/07/14Kafka Controller Redesign 方案
2018/07/08分布式系统的一致性协议之 2PC 和 3PC
2018/07/07Java 守护线程
2018/06/27Kafka 源码解析之 Server 1+N+M 网络处理模型（二十三）
2018/06/25Kafka 源码解析之 LeaderAndIsr 请求的处理（二十二）
2018/06/23Kafka 源码解析之 Controller 发送模型（二十一）
2018/06/18Kafka 源码解析之 Topic 的新建/扩容/删除（二十）
2018/06/17Kafka 源码解析之 Broker 上线下线（十九）
2018/06/16Kafka 源码解析之 Partition 副本迁移实现（十八）
2018/06/16Kafka 源码解析之副本状态机与分区状态机（十七）
2018/06/15Kafka 源码解析之 Controller 选举及服务启动流程（十六）
2018/05/01Kafka 源码解析之 ReplicaManager 详解（十五）
2018/04/29Kafka 源码解析之副本同步机制实现（十四）
2018/04/15Kafka 源码解析之 Server 端如何处理 Fetch 请求（十三）
2018/03/18Kafka 源码解析之 Server 端如何处理 Produce 请求（十二）
2018/03/12Kafka 源码解析之日志管理（十一）
2018/02/04操作系统之共享对象学习
2018/01/28Kafka 源码解析之 GroupCoordinator 详解（十）

2017

2017/12/17自我救赎
2017/11/19Kafka 源码解析之 Consumer 两种 commit 机制和 partition 分配机制（九）
2017/11/18Kafka 源码解析之 Consumer 两种订阅模式（八）
2017/11/11Kafka 源码解析之 Consumer Poll 模型（七）
2017/10/22Kafka 源码解析之 Consumer 如何加入一个 Group（六）
2017/09/10Kafka 源码解析之 Producer 单 Partition 顺序性实现及配置说明（五）