【文件属性】：
文件名称：JobGraph的生成-svpwm的调制及谐波分析
文件大小：4.81MB
文件格式：PDF
更新时间：2024-07-10 12:54:41
flink
2.3 JobGraph的生成
flink会根据上一步生成的StreamGraph生成JobGraph，然后将JobGraph发送到server端进
行ExecutionGraph的解析。
2.3.1 JobGraph生成源码
与StreamGraph类似，JobGraph的入口方法
是 StreamingJobGraphGenerator.createJobGraph() 。我们直接来看源码
1. private JobGraph createJobGraph() {
2.
3. // 设置启动模式为所有节点均在一开始就启动
4. jobGraph.setScheduleMode(ScheduleMode.EAGER);
5.
6. // 为每个节点生成hash id
7. Map hashes = defaultStreamGraphHasher.traverse
StreamGraphAndGenerateHashes(streamGraph);
8.
9. // 为了保持兼容性创建的hash
10. List> legacyHashes = new ArrayList<>(legac
yStreamGraphHashers.size());
11. for (StreamGraphHasher hasher : legacyStreamGraphHashers) {
12.
legacyHashes.add(hasher.traverseStreamGraphAndGenerateHashes(streamGrap
h));
13. }
14.
15. Map>>
chainedOperatorHashes = new HashMap<>();
16. //生成jobvertex，串成chain等
17. //这里的逻辑大致可以理解为，挨个遍历节点，如果该节点是一个chain的头节点，
就生成一个JobVertex，如果不是头节点，就要把自身配置并入头节点，然后把头节点和自己
的出边相连；对于不能chain的节点，当作只有头节点处理即可
18. setChaining(hashes, legacyHashes, chainedOperatorHashes);
19. //设置输入边edge
20. setPhysicalEdges();
21. //设置slot共享group
22. setSlotSharing();
23. //配置检查点
24. configureCheckpointing();
25.
26. // 如果有之前的缓存文件的配置的话，重新读入
