Uses of Class
org.apache.flink.client.program.ProgramInvocationException

Packages that use ProgramInvocationException

Package	Description
org.apache.flink.api.java
org.apache.flink.client.cli
org.apache.flink.client.program
org.apache.flink.client.program.rest
org.apache.flink.streaming.api.environment
org.apache.flink.yarn

Uses of ProgramInvocationException in org.apache.flink.api.java

Methods in org.apache.flink.api.java that throw ProgramInvocationException

Modifier and Type	Method and Description
protected JobExecutionResult	ScalaShellRemoteStreamEnvironment.executeRemotely(StreamGraph streamGraph, List<URL> jarFiles) Executes the remote job.

Uses of ProgramInvocationException in org.apache.flink.client.cli

Methods in org.apache.flink.client.cli that throw ProgramInvocationException

Modifier and Type	Method and Description
protected void	CliFrontend.executeProgram(PackagedProgram program, ClusterClient<?> client, int parallelism)
protected void	CliFrontend.info(String[] args) Executes the info action.

Uses of ProgramInvocationException in org.apache.flink.client.program

Methods in org.apache.flink.client.program that throw ProgramInvocationException

Modifier and Type	Method and Description
static JobGraph	PackagedProgramUtils.createJobGraph(PackagedProgram packagedProgram, Configuration configuration, int defaultParallelism) Creates a JobGraph from the given PackagedProgram.
static List<File>	PackagedProgram.extractContainedLibraries(URL jarFile) Takes all JAR files that are contained in this program's JAR file and extracts them to the system's temp directory.
String	PackagedProgram.getDescription() Returns the description provided by the Program class.
static JobGraph	ClusterClient.getJobGraph(Configuration flinkConfig, PackagedProgram prog, FlinkPlan optPlan, SavepointRestoreSettings savepointSettings)
static FlinkPlan	ClusterClient.getOptimizedPlan(Optimizer compiler, PackagedProgram prog, int parallelism)
FlinkPlan	OptimizerPlanEnvironment.getOptimizedPlan(PackagedProgram prog)
static String	ClusterClient.getOptimizedPlanAsJson(Optimizer compiler, PackagedProgram prog, int parallelism)
JobWithJars	PackagedProgram.getPlanWithJars() Returns the plan with all required jars.
JobWithJars	PackagedProgram.getPlanWithoutJars() Returns the plan without the required jars when the files are already provided by the cluster.
String	PackagedProgram.getPreviewPlan() Returns the analyzed plan without any optimizations.
void	PackagedProgram.invokeInteractiveModeForExecution() This method assumes that the context environment is prepared, or the execution will be a local execution by default.
JobSubmissionResult	ClusterClient.run(FlinkPlan compiledPlan, List<URL> libraries, List<URL> classpaths, ClassLoader classLoader)
JobSubmissionResult	ClusterClient.run(FlinkPlan compiledPlan, List<URL> libraries, List<URL> classpaths, ClassLoader classLoader, SavepointRestoreSettings savepointSettings)
JobExecutionResult	ClusterClient.run(JobGraph jobGraph, ClassLoader classLoader) Submits a JobGraph blocking.
JobSubmissionResult	ClusterClient.run(JobWithJars program, int parallelism)
JobSubmissionResult	ClusterClient.run(JobWithJars jobWithJars, int parallelism, SavepointRestoreSettings savepointSettings) Runs a program on the Flink cluster to which this client is connected.
JobSubmissionResult	ClusterClient.run(PackagedProgram prog, int parallelism) General purpose method to run a user jar from the CliFrontend in either blocking or detached mode, depending on whether setDetached(true) or setDetached(false).
JobSubmissionResult	ClusterClient.runDetached(JobGraph jobGraph, ClassLoader classLoader) Submits a JobGraph detached.
JobSubmissionResult	StandaloneClusterClient.submitJob(JobGraph jobGraph, ClassLoader classLoader)
abstract JobSubmissionResult	ClusterClient.submitJob(JobGraph jobGraph, ClassLoader classLoader) Calls the subclasses' submitJob method.
JobSubmissionResult	MiniClusterClient.submitJob(JobGraph jobGraph, ClassLoader classLoader)

Constructors in org.apache.flink.client.program that throw ProgramInvocationException

Constructor and Description
PackagedProgram(File jarFile, List<URL> classpaths, String... args) Creates an instance that wraps the plan defined in the jar file using the given argument.
PackagedProgram(File jarFile, List<URL> classpaths, String entryPointClassName, String... args) Creates an instance that wraps the plan defined in the jar file using the given arguments.
PackagedProgram(File jarFile, String... args) Creates an instance that wraps the plan defined in the jar file using the given argument.
PackagedProgram(File jarFile, String entryPointClassName, String... args) Creates an instance that wraps the plan defined in the jar file using the given arguments.

Uses of ProgramInvocationException in org.apache.flink.client.program.rest

Methods in org.apache.flink.client.program.rest that throw ProgramInvocationException

Modifier and Type	Method and Description
JobSubmissionResult	RestClusterClient.submitJob(JobGraph jobGraph, ClassLoader classLoader)

Uses of ProgramInvocationException in org.apache.flink.streaming.api.environment

Methods in org.apache.flink.streaming.api.environment that throw ProgramInvocationException

Modifier and Type	Method and Description
JobExecutionResult	RemoteStreamEnvironment.execute(String jobName)
protected JobExecutionResult	RemoteStreamEnvironment.executeRemotely(StreamGraph streamGraph, List<URL> jarFiles) Executes the remote job.

Uses of ProgramInvocationException in org.apache.flink.yarn

Methods in org.apache.flink.yarn that throw ProgramInvocationException

Modifier and Type	Method and Description
JobSubmissionResult	YarnClusterClient.submitJob(JobGraph jobGraph, ClassLoader classLoader)