Flink Yarn Per Job - 提交流程一_yarndeploymentexception: the flink jar path is nul-CSDN博客

网站介绍:文章浏览阅读613次。/构建nodechains,返回当前节点的物理出边;TODO将每个JobVertex的入边集合也序列化到该JobVertex的StreamConfig中(出边集合已经在setChaining的时候写入了)TODO过渡用的出边集合,用来生成最终的JobEdge,注意不包括chain内部的边。//保证如果提交的拓扑没有改变,则每次生成的hash都是一样的。..._yarndeploymentexception: the flink jar path is null