Package org.apache.flink.client.deployment.application

Class UnsuccessfulExecutionException

java.lang.Object

java.lang.Throwable

java.lang.Exception

org.apache.flink.util.FlinkException

org.apache.flink.runtime.client.JobExecutionException

org.apache.flink.client.deployment.application.UnsuccessfulExecutionException

All Implemented Interfaces:

Serializable

@Internal
public class UnsuccessfulExecutionException
extends JobExecutionException

Exception that signals the failure of an application with a given ApplicationStatus.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
UnsuccessfulExecutionException(JobID jobID, ApplicationStatus status, String message, Throwable cause)

Method Summary

Modifier and Type	Method	Description
static UnsuccessfulExecutionException	fromJobResult(JobResult result, ClassLoader userClassLoader)
ApplicationStatus	getStatus()

Methods inherited from class org.apache.flink.runtime.client.JobExecutionException

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

UnsuccessfulExecutionException

public UnsuccessfulExecutionException(JobID jobID,
                                      ApplicationStatus status,
                                      String message,
                                      Throwable cause)

Method Detail

getStatus

public ApplicationStatus getStatus()

fromJobResult

public static UnsuccessfulExecutionException fromJobResult(JobResult result,
                                                           ClassLoader userClassLoader)