You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by tison <wa...@gmail.com> on 2020/01/08 03:08:09 UTC
Re: jobgraph 生成
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
>>
>> <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> 定制
>>
>
Re: jobgraph 生成
Posted by tison <wa...@gmail.com>.
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 <wa...@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 <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
>>>
>>> <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> 定制
>>>
>>
回复：jobgraph 生成
Posted by 张江 <zj...@163.com>.
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
|
签名由 网易邮箱大师 定制
Re: jobgraph 生成
Posted by tison <wa...@gmail.com>.
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 <wa...@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 <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
>>>
>>> <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> 定制
>>>
>>
回复：jobgraph 生成
Posted by 张江 <zj...@163.com>.
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
|
签名由 网易邮箱大师 定制