flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From 张江 <zjkingdom2...@163.com>
Subject 回复:jobgraph 生成
Date Wed, 08 Jan 2020 04:09:33 GMT
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 <wander4096@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




张江 <zjkingdom2010@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
|

签名由 网易邮箱大师 定制
Mime
  • Unnamed multipart/related (inline, None, 0 bytes)
View raw message