Package | Description |
---|---|
org.apache.flink.client.program | |
org.apache.flink.runtime.client | |
org.apache.flink.runtime.executiongraph | |
org.apache.flink.runtime.messages |
This package contains the messages that are sent between actors, like the
JobManager and
TaskManager to coordinate the distributed operations. |
org.apache.flink.runtime.minicluster |
Class and Description |
---|
JobExecutionException
This exception is the base exception for all exceptions that denote any failure during
the execution of a job.
|
JobListeningContext
The JobListeningContext holds the state necessary to monitor a running job and receive its results.
|
Class and Description |
---|
JobClientActor
Actor which constitutes the bridge between the non-actor code and the JobManager.
|
JobExecutionException
This exception is the base exception for all exceptions that denote any failure during
the execution of a job.
|
JobListeningContext
The JobListeningContext holds the state necessary to monitor a running job and receive its results.
|
JobRetrievalException
Exception used to indicate that a job couldn't be retrieved from the JobManager
|
Class and Description |
---|
JobExecutionException
This exception is the base exception for all exceptions that denote any failure during
the execution of a job.
|
Class and Description |
---|
JobStatusMessage
A simple message that holds the state of a job execution.
|
SerializedJobExecutionResult
A variant of the
JobExecutionResult that holds
its accumulator data in serialized form. |
Class and Description |
---|
JobExecutionException
This exception is the base exception for all exceptions that denote any failure during
the execution of a job.
|
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.