How to find the relation between a running job and the original jar?

classic Classic list List threaded Threaded
5 messages Options
Reply | Threaded
Open this post in threaded view
|

How to find the relation between a running job and the original jar?

Lasse Nedergaard
Hi.

I working on a solution where I want to check if a running job use the right jar in the right version.

Anyone knows if it is possible through the REST API to find information about a running job that contains the jarid or something simillary so it is possible to lookup the original jar?

Need to work for Flink 1.5.0 or 1.4.2

Any help appreciated 

Thanks in advance

Lasse Nedergaard

Reply | Threaded
Open this post in threaded view
|

答复: How to find the relation between a running job and the original jar?

Yun Tang
Hi Lasse

   As far as I know, if you use post /jars/upload REST API to submit your job, you can then get /jars to list your user jar just uploaded. More information can refer to https://ci.apache.org/projects/flink/flink-docs-release-1.5/monitoring/rest_api.html#dispatcher
Thanks, Yun

发件人: Lasse Nedergaard <[hidden email]>
发送时间: 2018年7月10日 17:40
收件人: user
主题: How to find the relation between a running job and the original jar?
 
Hi.

I working on a solution where I want to check if a running job use the right jar in the right version.

Anyone knows if it is possible through the REST API to find information about a running job that contains the jarid or something simillary so it is possible to lookup the original jar?

Need to work for Flink 1.5.0 or 1.4.2

Any help appreciated 

Thanks in advance

Lasse Nedergaard

Reply | Threaded
Open this post in threaded view
|

Re: 答复: How to find the relation between a running job and the original jar?

Lasse Nedergaard
Hi Tang

Thanks for the link. Yes your are rights and it works fine. But when I use the REST API for getting running jobs I can’t find any reference back to the jar used to start the job. 

Med venlig hilsen / Best regards
Lasse Nedergaard


Den 11. jul. 2018 kl. 05.22 skrev Tang Cloud <[hidden email]>:

Hi Lasse

   As far as I know, if you use post /jars/upload REST API to submit your job, you can then get /jars to list your user jar just uploaded. More information can refer to https://ci.apache.org/projects/flink/flink-docs-release-1.5/monitoring/rest_api.html#dispatcher
Thanks, Yun

发件人: Lasse Nedergaard <[hidden email]>
发送时间: 2018年7月10日 17:40
收件人: user
主题: How to find the relation between a running job and the original jar?
 
Hi.

I working on a solution where I want to check if a running job use the right jar in the right version.

Anyone knows if it is possible through the REST API to find information about a running job that contains the jarid or something simillary so it is possible to lookup the original jar?

Need to work for Flink 1.5.0 or 1.4.2

Any help appreciated 

Thanks in advance

Lasse Nedergaard

Reply | Threaded
Open this post in threaded view
|

Re: 答复: How to find the relation between a running job and the original jar?

Chesnay Schepler
For a running job there is no way to determine which jar was originally used for it.

I remember a previous request for this feature, but I don't think a JIRA was created for it.
Might be a good time to create one now.

Could you open one and specify your requirements?

On 11.07.2018 06:33, Lasse Nedergaard wrote:
Hi Tang

Thanks for the link. Yes your are rights and it works fine. But when I use the REST API for getting running jobs I can’t find any reference back to the jar used to start the job. 

Med venlig hilsen / Best regards
Lasse Nedergaard


Den 11. jul. 2018 kl. 05.22 skrev Tang Cloud <[hidden email]>:

Hi Lasse

   As far as I know, if you use post /jars/upload REST API to submit your job, you can then get /jars to list your user jar just uploaded. More information can refer to https://ci.apache.org/projects/flink/flink-docs-release-1.5/monitoring/rest_api.html#dispatcher
Thanks, Yun

发件人: Lasse Nedergaard <[hidden email]>
发送时间: 2018年7月10日 17:40
收件人: user
主题: How to find the relation between a running job and the original jar?
 
Hi.

I working on a solution where I want to check if a running job use the right jar in the right version.

Anyone knows if it is possible through the REST API to find information about a running job that contains the jarid or something simillary so it is possible to lookup the original jar?

Need to work for Flink 1.5.0 or 1.4.2

Any help appreciated 

Thanks in advance

Lasse Nedergaard


Reply | Threaded
Open this post in threaded view
|

Re: 答复: How to find the relation between a running job and the original jar?

Lasse Nedergaard
Hi Chesnay

Please let me know if I can do anything to help implementing it. 

Lasse 

2018-07-11 9:08 GMT+02:00 Chesnay Schepler <[hidden email]>:
For a running job there is no way to determine which jar was originally used for it.

I remember a previous request for this feature, but I don't think a JIRA was created for it.
Might be a good time to create one now.

Could you open one and specify your requirements?


On 11.07.2018 06:33, Lasse Nedergaard wrote:
Hi Tang

Thanks for the link. Yes your are rights and it works fine. But when I use the REST API for getting running jobs I can’t find any reference back to the jar used to start the job. 

Med venlig hilsen / Best regards
Lasse Nedergaard


Den 11. jul. 2018 kl. 05.22 skrev Tang Cloud <[hidden email]>:

Hi Lasse

   As far as I know, if you use post /jars/upload REST API to submit your job, you can then get /jars to list your user jar just uploaded. More information can refer to https://ci.apache.org/projects/flink/flink-docs-release-1.5/monitoring/rest_api.html#dispatcher
Flink has a monitoring API that can be used to query status and statistics of running jobs, as well as recent completed jobs. This monitoring API is used by Flink’s own dashboard, but is designed to be used also by custom monitoring tools. The monitoring API is a REST-ful API that accepts HTTP ...
Thanks, Yun

发件人: Lasse Nedergaard <[hidden email]>
发送时间: 2018年7月10日 17:40
收件人: user
主题: How to find the relation between a running job and the original jar?
 
Hi.

I working on a solution where I want to check if a running job use the right jar in the right version.

Anyone knows if it is possible through the REST API to find information about a running job that contains the jarid or something simillary so it is possible to lookup the original jar?

Need to work for Flink 1.5.0 or 1.4.2

Any help appreciated 

Thanks in advance

Lasse Nedergaard