Get the JobID when Flink job fails

[Vinay Patil]

Hi,

When the Flink job executes successfully I get the jobID, however when the Flink job fails the jobID is not returned.

How do I get the jobId in this case ? 

Do I need to call /joboverview REST api to get the job ID by  looking for the Job Name ?

[Vinay Patil]

Hi,

I see we can generate our own JobID, but how do I use it to submit the job to the cluster.

I am using remoteExecutionEnvironment to submit the job to the cluster.

Also, can you please answer the query of earlier mail.

On Thu, Feb 1, 2018 at 1:50 PM, Vinay Patil <[hidden email]> wrote:

Hi,

When the Flink job executes successfully I get the jobID, however when the Flink job fails the jobID is not returned.

How do I get the jobId in this case ? 

Do I need to call /joboverview REST api to get the job ID by  looking for the Job Name ?

[Chesnay Schepler]

Yes I think that's the only way to get it. I'll open a JIRA to print the JobID also for failed jobs.

On 01.02.2018 20:50, Vinay Patil wrote:

Hi,

When the Flink job executes successfully I get the jobID, however when the Flink job fails the jobID is not returned.

How do I get the jobId in this case ? 

Do I need to call /joboverview REST api to get the job ID by  looking for the Job Name ?

[Chesnay Schepler]

As far as i know there's no way to specify the JobID when submitting a job.

I've responded to your previous question in a separate mail.

On 06.02.2018 18:14, Vinay Patil wrote:

Hi,

I see we can generate our own JobID, but how do I use it to submit the job to the cluster.

I am using remoteExecutionEnvironment to submit the job to the cluster.

Also, can you please answer the query of earlier mail.

On Thu, Feb 1, 2018 at 1:50 PM, Vinay Patil <[hidden email]> wrote:

Hi,

When the Flink job executes successfully I get the jobID, however when the Flink job fails the jobID is not returned.

How do I get the jobId in this case ? 

Do I need to call /joboverview REST api to get the job ID by  looking for the Job Name ?