Package org.apache.flink.runtime.client

Class JobExecutionException

java.lang.Object

java.lang.Throwable

java.lang.Exception

org.apache.flink.util.FlinkException

org.apache.flink.runtime.client.JobExecutionException

All Implemented Interfaces:

Serializable

Direct Known Subclasses:

JobCancellationException, JobInitializationException, JobSubmissionException, UnsuccessfulExecutionException

public class JobExecutionException
extends FlinkException

This exception is the base exception for all exceptions that denote any failure during the execution of a job.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
JobExecutionException(JobID jobID, String msg)
JobExecutionException(JobID jobID, String msg, Throwable cause)	Constructs a new job execution exception.
JobExecutionException(JobID jobID, Throwable cause)

Method Summary

Modifier and Type	Method	Description
JobID	getJobID()

Methods inherited from class java.lang.Throwable

addSuppressed, fillInStackTrace, getCause, getLocalizedMessage, getMessage, getStackTrace, getSuppressed, initCause, printStackTrace, printStackTrace, printStackTrace, setStackTrace, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

JobExecutionException

public JobExecutionException(JobID jobID,
                             String msg,
                             Throwable cause)

Constructs a new job execution exception.

Parameters:

jobID - The job's ID.

msg - The cause for the execution exception.

cause - The cause of the exception

JobExecutionException

public JobExecutionException(JobID jobID,
                             String msg)

JobExecutionException

public JobExecutionException(JobID jobID,
                             Throwable cause)

Method Detail

getJobID

public JobID getJobID()