You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@flink.apache.org by 张江 <zj...@163.com> on 2020/01/08 04:09:33 UTC

回复:jobgraph 生成

Very sorry for the wrong operation. I copied the wrong email address by the phone.


Thank you for your reply.


| |
张江
|
|
邮箱:zjkingdom2010@163.com
|

签名由 网易邮箱大师 定制

在2020年01月08日 11:08,tison 写道:
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 <wa...@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




张江 <zj...@163.com> 于2020年1月8日周三 上午11:01写道:

大家好,


通过调用env.getExecutionPlan可以以json格式得到streamGraph,放到flink visualizer里可以得到可视化结果。现在我想以类似方法得到 jobGraph,生成jobGraph的json文件。不知道应该怎么做?


flink里似乎没有直接的API可以调用,但是我在flink web ui界面上可以看到job经过chain后的执行图,如下图所示。这个是怎么生成的?




谢谢


| |
张江
|
|
邮箱:zjkingdom2010@163.com
|

签名由 网易邮箱大师 定制