标签: 源码分析 | 程序员笔记

跳表 1 事务 1 clickhouse 1 数据传输 1 MemoryManagment 1 Slot 1 HA 1 Akka 1 RPC 1 ExecutionGraph 1 JobGraph 1 源码分析 3 StreamGraph 1 savepoint savepoint 1 ConcurrentHashMap 1 ORC 1 snapshot 1 ABS算法 1 lock 2 thread 1 kafka-producer 1 kafkaproducer partition 1 cgroup 1 HBase 1 LSM 2 B+树 1 SecondaryNmenode 1 NameNode 1 令牌桶 1 Guava 1 Flink CDC 1 Flink SQL 4 最佳实践 6 资源管理 2 维度表 1 调度 4 流批一体 2 join 2 Chain 1 Operator 1 ClassLoader 1 RocksDB 2 time 2 window 2 checkpoint 8 网络优化 1 watermark 3 背压 2 CEP 1 Shuffle 3 精确一致性 3 窗口 1 kafka-consumer 2 view 1 transformation 1 state 10 kudu 2 impala 2 内存管理 4 GC 1 Exception 1 多线程 1 YARN 1 MapReduce 2 HDFS 2 hadoop 0 Halo 0

bigdataflink 未读

Flink 源码阅读笔记（5）- 集群启动流程

在 Flink 1.5.0 版本发布的时候，Flink 迎来了一个重要的改进：根据 FLIP-6 重构了 Flink 集群部署和任务处理模型，以便更好地和管理资源和调度任务，更优雅地和 Yarn、 Mesos、Kubernetes 等框架进行集成。在这篇文章中，我们将对 Flink 集群的启动流程

源码分析 HA 2021-10-17

bigdataflink 未读

Flink 源码阅读笔记（2）- JobGraph 的生成

前面的文章我们介绍了 StreamGraph 的生成，这个实际上只对应 Flink 作业在逻辑上的执行计划图。Flink 会进一步对 StreamGraph 进行转换，得到另一个执行计划图，即 JobGraph。 JobVertex 在 StreamGraph 中，每一个算子（Operator）对

JobGraph 源码分析 2021-10-10

bigdataflink 未读

Flink 源码阅读笔记（1）- StreamGraph 的生成

在编写 Flink 的程序的时候，核心的要点是构造出数据处理的拓扑结构，即任务执行逻辑的 DAG。我们先来看一下 Flink 任务的拓扑在逻辑上是怎么保存的。 StreamExecutionEnvironment StreamExecutionEnvironment 是 Flink 在流模式下任务执

StreamGraph 源码分析 2021-10-10