A public way to get JSON plan of a JobGraph is, with an existing Flink Cluster, use REST API JarPlan[1].
Best, tison. [1] https://ci.apache.org/projects/flink/flink-docs-master/monitoring/rest_api.html#jars-jarid-plan tison <wander4...@gmail.com> 于2020年1月8日周三 上午11:08写道： > Hi Zhang, > > I just notice that it is sent to user list. Please send to user-zh list(in > cc) next time if you want to discuss in Chinese. > > Best, > tison. > > > tison <wander4...@gmail.com> 于2020年1月8日周三 上午11:06写道： > >> 如果你是流作业的话，参考这个页面[1]搞到 JobGraph 之后可以 >> >> JsonPlanGenerator.generatePlan(jobGraph) >> >> 拿到 JobGraph 的 JSON。不过这个是非常内部的逻辑，没有任何兼容性保障。 >> >> Best, >> tison. >> >> [1] >> https://ci.apache.org/projects/flink/flink-docs-release-1.8/ops/deployment/mesos.html#flink-job-cluster-on-mesos >> >> >> 张江 <zjkingdom2...@163.com> 于2020年1月8日周三 上午11:01写道： >> >>> 大家好， >>> >>> 通过调用env.getExecutionPlan可以以json格式得到streamGraph，放到flink >>> visualizer里可以得到可视化结果。现在我想以类似方法得到 jobGraph，生成jobGraph的json文件。不知道应该怎么做？ >>> >>> flink里似乎没有直接的API可以调用，但是我在flink web >>> ui界面上可以看到job经过chain后的执行图，如下图所示。这个是怎么生成的？ >>> >>> >>> 谢谢 >>> >>> 张江 >>> 邮箱：zjkingdom2...@163.com >>> >>> <https://maas.mail.163.com/dashi-web-extend/html/proSignature.html?ftlId=1&name=%E5%BC%A0%E6%B1%9F&uid=zjkingdom2010%40163.com&iconUrl=https%3A%2F%2Fmail-online.nosdn.127.net%2Fqiyelogo%2FdefaultAvatar.png&items=%5B%22%E9%82%AE%E7%AE%B1%EF%BC%9Azjkingdom2010%40163.com%22%5D> >>> >>> 签名由 网易邮箱大师 <https://mail.163.com/dashi/dlpro.html?from=mail88> 定制 >>> >>
