HeapStateBackend 与 RocksDBStateBackend 的源码对比与选型建议。

Credit-based Flow Control 详解。Flink 如何优雅地处理下游消费不过来的情况。

JobMaster 如何将 JobGraph 转化为可执行的 ExecutionGraph，并申请 Slot。

Flink 源码目录结构详解。flink-runtime, flink-streaming-java, flink-core 等模块的功能定位。

Flink 如何通过 Operator Chain 减少序列化开销和线程切换。

基于 ZooKeeper 和 Kubernetes 的 Leader 选举与元数据存储。

基于 Akka 的控制流 RPC 与基于 Netty 的数据流传输。

Code Generation 技术详解。为什么 Flink SQL 比手写 Java 代码还快？

TaskManager 如何启动 Task？Slot、Task、SubTask 的关系，以及 Task 线程模型。

Flink 如何高效管理数百万个定时器？基于时间轮 (Timing Wheel) 还是优先队列？

水位线 (Watermark) 的生成、传播与处理乱序数据的原理。

Flink 如何管理堆外内存？MemorySegment 与 Network Buffer 的设计。

DataStream API 如何转化为流图。StreamGraphGenerator 源码解析。

窗口分配器 (Assigner)、触发器 (Trigger) 与驱逐器 (Evictor) 的实现。

Chandy-Lamport 算法在 Flink 中的实现。Barrier 对齐与异步快照。

Flink Cluster 的启动流程，从 Entrypoint 到 Dispatcher 和 ResourceManager 的初始化。

从 SQL 语句到 Physical Plan。Calcite 在 Flink SQL 中的应用。

Apache Flink 源码阅读系列大纲。从 JobGraph 到 Task 调度，从 Checkpoint 到反压机制，全链路源码解析。

Client 端如何将用户代码转化为 JobGraph，并提交给 Dispatcher。

工欲善其事，必先利其器。如何编译 Flink 源码，并在 IDEA 中运行 WordCount 示例进行 Debug。