标签: JobGraph | 程序员笔记

互动

最近评论

标签

寻找感兴趣的领域

文章

跳表 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

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

bigdataflink 未读

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

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

JobGraph 源码分析 2021-10-10