jobgraph 生成

[张江]

大家好，

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

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

谢谢

	张江
邮箱：zjkingdom2010@...

签名由 网易邮箱大师 定制

[tison]

如果你是流作业的话，参考这个页面[1]搞到 JobGraph 之后可以

JsonPlanGenerator.generatePlan(jobGraph)

拿到 JobGraph 的 JSON。不过这个是非常内部的逻辑，没有任何兼容性保障。

张江 <[hidden email]> 于2020年1月8日周三 上午11:01写道：

大家好，

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

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

谢谢

	张江
邮箱：zjkingdom2010@...

签名由 网易邮箱大师 定制

[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.

tison <[hidden email]> 于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

张江 <[hidden email]> 于2020年1月8日周三 上午11:01写道：

大家好，

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

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

谢谢

	张江
邮箱：zjkingdom2010@...

签名由 网易邮箱大师 定制

[tison]

A public way to get JSON plan of a JobGraph is, with an existing Flink Cluster, use REST API JarPlan[1].

tison <[hidden email]> 于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 <[hidden email]> 于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

张江 <[hidden email]> 于2020年1月8日周三 上午11:01写道：

大家好，

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

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

谢谢

	张江
邮箱：zjkingdom2010@...

签名由 网易邮箱大师 定制

[张江]

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

Thank you for your reply.

	张江
邮箱：zjkingdom2010@...

签名由 网易邮箱大师 定制

在2020年01月08日 11:08，[hidden email] 写道：

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.

tison <[hidden email]> 于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

张江 <[hidden email]> 于2020年1月8日周三 上午11:01写道：

大家好，

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

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

谢谢

	张江
邮箱：zjkingdom2010@...

签名由 网易邮箱大师 定制