Sql作业好像不支持修改每个算子并行度吧,修改并行度需要从头开始重新生成JobGraph提交作业。 Json主要是贴到Plan Visualizer 开发和调试用。 https://flink.apache.org/visualizer/ 从 Windows 版邮件发送
发件人: yidan zhao 发送时间: 2022年11月30日 10:12 收件人: user-zh@flink.apache.org 主题: Re: Re: 怎样从flink执行计划json生成StreamGraph? 好吧,sql我具体不了解,我用的stream api比较多,我了解是stream api到streamGraph,然后到jobGraph,然后就是直接rest api方式提交给集群执行。 standalone场景。 casel.chen <casel_c...@126.com> 于2022年11月30日周三 00:16写道: > > 如果要支持调整flink sql作业每个算子资源和并行度的话,不是要从json转回streamGraph再提交吗? > > > > > > > > > > > > > > > > > > 在 2022-11-29 10:07:40,"yidan zhao" <hinobl...@gmail.com> 写道: > >并不需要从执行计划json生成streamGraph呀~ > >streamGraph提交之前直接转jobGraph。 > > > >casel.chen <casel_c...@126.com> 于2022年11月28日周一 08:53写道: > >> > >> 源码中只找到如何从streamgraph生成执行计划的json串,但没有找到如何解析执行计划的json串生成回streamgraph,还请赐教