好吧,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,还请赐教