如果你是流作业的话,参考这个页面[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> 定制
>

Reply via email to