Serialized Form (flink-runtime 0.9.0 API)

Package org.apache.flink.runtime
- Class org.apache.flink.runtime.JobException extends Exception implements Serializable
  
  serialVersionUID:
  
  1275864691743020176L
Package org.apache.flink.runtime.accumulators
- Class org.apache.flink.runtime.accumulators.AccumulatorEvent extends SerializedValue<Map<String,org.apache.flink.api.common.accumulators.Accumulator<?,?>>> implements Serializable
  
  serialVersionUID:
  
  8965894516006882735L
  - Serialized Fields
    - jobID
```
org.apache.flink.api.common.JobID jobID
```
      JobID for the target job
- Class org.apache.flink.runtime.accumulators.StringifiedAccumulatorResult extends Object implements Serializable
  
  serialVersionUID:
  
  -4642311296836822611L
  - Serialized Fields
    - name
```
String name
```
    - type
```
String type
```
    - value
```
String value
```
Package org.apache.flink.runtime.blob
- Class org.apache.flink.runtime.blob.BlobKey extends Object implements Serializable
  
  serialVersionUID:
  
  3847117712521785209L
  - Serialized Fields
    - key
```
byte[] key
```
      The byte buffer storing the actual key data.
Package org.apache.flink.runtime.broadcast
- Class org.apache.flink.runtime.broadcast.InitializationTypeConflictException extends Exception implements Serializable
  
  serialVersionUID:
  
  -3930913982433642882L
  - Serialized Fields
    - type
```
Class<T> type
```
- Class org.apache.flink.runtime.broadcast.MaterializationExpiredException extends Exception implements Serializable
  
  serialVersionUID:
  
  7476456353634121934L
Package org.apache.flink.runtime.client
- Class org.apache.flink.runtime.client.JobCancellationException extends JobExecutionException implements Serializable
  
  serialVersionUID:
  
  2818087325120827526L
- Class org.apache.flink.runtime.client.JobExecutionException extends Exception implements Serializable
  
  serialVersionUID:
  
  2818087325120827525L
  - Serialized Fields
    - jobID
```
org.apache.flink.api.common.JobID jobID
```
- Class org.apache.flink.runtime.client.JobStatusMessage extends Object implements Serializable
  - Serialized Fields
    - jobId
```
org.apache.flink.api.common.JobID jobId
```
    - jobName
```
String jobName
```
    - jobState
```
JobStatus jobState
```
    - startTime
```
long startTime
```
- Class org.apache.flink.runtime.client.JobSubmissionException extends JobExecutionException implements Serializable
  
  serialVersionUID:
  
  2818087325120827526L
- Class org.apache.flink.runtime.client.JobTimeoutException extends JobExecutionException implements Serializable
  
  serialVersionUID:
  
  2818087325120827529L
- Class org.apache.flink.runtime.client.SerializedJobExecutionResult extends Object implements Serializable
  
  serialVersionUID:
  
  -6301865617099921789L
  - Serialized Fields
    - jobId
```
org.apache.flink.api.common.JobID jobId
```
    - accumulatorResults
```
Map<K,V> accumulatorResults
```
    - netRuntime
```
long netRuntime
```
Package org.apache.flink.runtime.deployment
- Class org.apache.flink.runtime.deployment.InputChannelDeploymentDescriptor extends Object implements Serializable
  - Serialized Fields
    - consumedPartitionId
```
ResultPartitionID consumedPartitionId
```
      The ID of the partition the input channel is going to consume.
    - consumedPartitionLocation
```
ResultPartitionLocation consumedPartitionLocation
```
      The location of the partition the input channel is going to consume.
- Class org.apache.flink.runtime.deployment.InputGateDeploymentDescriptor extends Object implements Serializable
  - Serialized Fields
    - consumedResultId
```
IntermediateDataSetID consumedResultId
```
      The ID of the consumed intermediate result. Each input gate consumes partitions of the intermediate result specified by this ID. This ID also identifies the input gate at the consuming task.
    - consumedSubpartitionIndex
```
int consumedSubpartitionIndex
```
      The index of the consumed subpartition of each consumed partition. This index depends on the DistributionPattern and the subtask indices of the producing and consuming task.
    - inputChannels
```
InputChannelDeploymentDescriptor[] inputChannels
```
      An input channel for each consumed subpartition.
- Class org.apache.flink.runtime.deployment.ResultPartitionDeploymentDescriptor extends Object implements Serializable
  - Serialized Fields
    - resultId
```
IntermediateDataSetID resultId
```
      The ID of the result this partition belongs to.
    - partitionId
```
IntermediateResultPartitionID partitionId
```
      The ID of the partition.
    - partitionType
```
ResultPartitionType partitionType
```
      The type of the partition.
    - numberOfSubpartitions
```
int numberOfSubpartitions
```
      The number of subpartitions.
- Class org.apache.flink.runtime.deployment.ResultPartitionLocation extends Object implements Serializable
  - Serialized Fields
    - locationType
```
org.apache.flink.runtime.deployment.ResultPartitionLocation.LocationType locationType
```
      The type of location for the result partition.
    - connectionId
```
ConnectionID connectionId
```
      The connection ID of a remote result partition.
- Class org.apache.flink.runtime.deployment.TaskDeploymentDescriptor extends Object implements Serializable
  
  serialVersionUID:
  
  -3233562176034358530L
  - Serialized Fields
    - jobID
```
org.apache.flink.api.common.JobID jobID
```
      The ID of the job the tasks belongs to.
    - vertexID
```
JobVertexID vertexID
```
      The task's job vertex ID.
    - executionId
```
ExecutionAttemptID executionId
```
      The ID referencing the attempt to execute the task.
    - taskName
```
String taskName
```
      The task's name.
    - indexInSubtaskGroup
```
int indexInSubtaskGroup
```
      The task's index in the subtask group.
    - numberOfSubtasks
```
int numberOfSubtasks
```
      The number of sub tasks.
    - jobConfiguration
```
org.apache.flink.configuration.Configuration jobConfiguration
```
      The configuration of the job the task belongs to.
    - taskConfiguration
```
org.apache.flink.configuration.Configuration taskConfiguration
```
      The task's configuration object.
    - invokableClassName
```
String invokableClassName
```
      The name of the class containing the task code to be executed.
    - producedPartitions
```
List<E> producedPartitions
```
      The list of produced intermediate result partition deployment descriptors.
    - inputGates
```
List<E> inputGates
```
      The list of consumed intermediate result partitions.
    - targetSlotNumber
```
int targetSlotNumber
```
    - requiredJarFiles
```
List<E> requiredJarFiles
```
      The list of JAR files required to run this task.
    - operatorState
```
SerializedValue<T> operatorState
```
Package org.apache.flink.runtime.event.job
- Class org.apache.flink.runtime.event.job.AbstractEvent extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - timestamp
```
long timestamp
```
      The timestamp of the event.
    - sequenceNumber
```
long sequenceNumber
```
      The sequence number of the event.
Package org.apache.flink.runtime.event.task
- Class org.apache.flink.runtime.event.task.EventList extends SerializableArrayList<AbstractEvent> implements Serializable
  
  serialVersionUID:
  
  4788250278393432776L
Package org.apache.flink.runtime.execution
- Class org.apache.flink.runtime.execution.CancelTaskException extends RuntimeException implements Serializable
  
  serialVersionUID:
  
  1L
Package org.apache.flink.runtime.executiongraph
- Class org.apache.flink.runtime.executiongraph.Execution extends Object implements Serializable
  
  serialVersionUID:
  
  42L
  - Serialized Fields
    - vertex
```
ExecutionVertex vertex
```
    - attemptId
```
ExecutionAttemptID attemptId
```
    - stateTimestamps
```
long[] stateTimestamps
```
    - attemptNumber
```
int attemptNumber
```
    - timeout
```
scala.concurrent.duration.FiniteDuration timeout
```
    - partialInputChannelDeploymentDescriptors
```
ConcurrentLinkedQueue<E> partialInputChannelDeploymentDescriptors
```
    - state
```
ExecutionState state
```
    - assignedResource
```
SimpleSlot assignedResource
```
    - failureCause
```
Throwable failureCause
```
    - assignedResourceLocation
```
InstanceConnectionInfo assignedResourceLocation
```
    - operatorState
```
SerializedValue<T> operatorState
```
- Class org.apache.flink.runtime.executiongraph.ExecutionAttemptID extends org.apache.flink.util.AbstractID implements Serializable
  
  serialVersionUID:
  
  -1169683445778281344L
- Class org.apache.flink.runtime.executiongraph.ExecutionGraph extends Object implements Serializable
  
  serialVersionUID:
  
  42L
  - Serialized Fields
    - progressLock
```
SerializableObject progressLock
```
      The lock used to secure all access to mutable fields, especially the tracking of progress within the job.
    - jobID
```
org.apache.flink.api.common.JobID jobID
```
      The ID of the job this graph has been built for.
    - jobName
```
String jobName
```
      The name of the original job graph.
    - jobConfiguration
```
org.apache.flink.configuration.Configuration jobConfiguration
```
      The job configuration that was originally attached to the JobGraph.
    - tasks
```
ConcurrentHashMap<K,V> tasks
```
      All job vertices that are part of this graph
    - verticesInCreationOrder
```
List<E> verticesInCreationOrder
```
      All vertices, in the order in which they were created
    - intermediateResults
```
ConcurrentHashMap<K,V> intermediateResults
```
      All intermediate results that are part of this graph
    - currentExecutions
```
ConcurrentHashMap<K,V> currentExecutions
```
      The currently executed tasks, for callbacks
    - requiredJarFiles
```
List<E> requiredJarFiles
```
      A list of all libraries required during the job execution. Libraries have to be stored inside the BlobService and are referenced via the BLOB keys.
    - jobStatusListenerActors
```
List<E> jobStatusListenerActors
```
      Listeners that receive messages when the entire job switches it status (such as from RUNNING to FINISHED)
    - executionListenerActors
```
List<E> executionListenerActors
```
      Listeners that receive messages whenever a single task execution changes its status
    - stateTimestamps
```
long[] stateTimestamps
```
      Timestamps (in milliseconds as returned by System.currentTimeMillis() when the execution graph transitioned into a certain state. The index into this array is the ordinal of the enum value, i.e. the timestamp when the graph went into state "RUNNING" is at stateTimestamps[RUNNING.ordinal()].
    - timeout
```
scala.concurrent.duration.FiniteDuration timeout
```
      The timeout for all messages that require a response/acknowledgement
    - numberOfRetriesLeft
```
int numberOfRetriesLeft
```
      The number of times failed executions should be retried.
    - delayBeforeRetrying
```
long delayBeforeRetrying
```
      The delay that the system should wait before restarting failed executions.
    - allowQueuedScheduling
```
boolean allowQueuedScheduling
```
      Flag to indicate whether the scheduler may queue tasks for execution, or needs to be able to deploy them immediately.
    - scheduleMode
```
ScheduleMode scheduleMode
```
      The mode of scheduling. Decides how to select the initial set of tasks to be deployed. May indicate to deploy all sources, or to deploy everything, or to deploy via backtracking from results than need to be materialized.
    - snapshotCheckpointsEnabled
```
boolean snapshotCheckpointsEnabled
```
      Flag that indicate whether the executed dataflow should be periodically snapshotted
    - state
```
JobStatus state
```
      Current status of the job execution
    - failureCause
```
Throwable failureCause
```
      The exception that caused the job to fail. This is set to the first root exception that was not recoverable and triggered job failure
    - numFinishedJobVertices
```
int numFinishedJobVertices
```
      The number of job vertices that have reached a terminal state
    - scheduler
```
Scheduler scheduler
```
      The scheduler to use for scheduling new tasks as they are needed
    - userClassLoader
```
ClassLoader userClassLoader
```
      The classloader for the user code. Needed for calls into user code classes
    - checkpointCoordinator
```
CheckpointCoordinator checkpointCoordinator
```
      The coordinator for checkpoints, if snapshot checkpoints are enabled
    - executionConfig
```
org.apache.flink.api.common.ExecutionConfig executionConfig
```
- Class org.apache.flink.runtime.executiongraph.ExecutionJobVertex extends Object implements Serializable
  
  serialVersionUID:
  
  42L
  - Serialized Fields
    - stateMonitor
```
SerializableObject stateMonitor
```
    - graph
```
ExecutionGraph graph
```
    - jobVertex
```
JobVertex jobVertex
```
    - taskVertices
```
ExecutionVertex[] taskVertices
```
    - producedDataSets
```
IntermediateResult[] producedDataSets
```
    - inputs
```
List<E> inputs
```
    - parallelism
```
int parallelism
```
    - finishedSubtasks
```
boolean[] finishedSubtasks
```
    - numSubtasksInFinalState
```
int numSubtasksInFinalState
```
    - slotSharingGroup
```
SlotSharingGroup slotSharingGroup
```
    - coLocationGroup
```
CoLocationGroup coLocationGroup
```
    - inputSplits
```
org.apache.flink.core.io.InputSplit[] inputSplits
```
    - inputSplitsPerSubtask
```
List<E>[] inputSplitsPerSubtask
```
    - splitAssigner
```
org.apache.flink.core.io.InputSplitAssigner splitAssigner
```
- Class org.apache.flink.runtime.executiongraph.ExecutionVertex extends Object implements Serializable
  
  serialVersionUID:
  
  42L
  - Serialized Fields
    - jobVertex
```
ExecutionJobVertex jobVertex
```
    - resultPartitions
```
Map<K,V> resultPartitions
```
    - inputEdges
```
ExecutionEdge[][] inputEdges
```
    - subTaskIndex
```
int subTaskIndex
```
    - priorExecutions
```
List<E> priorExecutions
```
    - timeout
```
scala.concurrent.duration.FiniteDuration timeout
```
    - locationConstraint
```
CoLocationConstraint locationConstraint
```
    - currentExecution
```
Execution currentExecution
```
    - locationConstraintInstances
```
List<E> locationConstraintInstances
```
    - scheduleLocalOnly
```
boolean scheduleLocalOnly
```
Package org.apache.flink.runtime.instance
- Class org.apache.flink.runtime.instance.HardwareDescription extends Object implements Serializable
  
  serialVersionUID:
  
  3380016608300325361L
  - Serialized Fields
    - numberOfCPUCores
```
int numberOfCPUCores
```
      The number of CPU cores available to the JVM on the compute node.
    - sizeOfPhysicalMemory
```
long sizeOfPhysicalMemory
```
      The size of physical memory in bytes available on the compute node.
    - sizeOfJvmHeap
```
long sizeOfJvmHeap
```
      The size of the JVM heap memory
    - sizeOfManagedMemory
```
long sizeOfManagedMemory
```
      The size of the memory managed by the system for caching, hashing, sorting, ...
- Class org.apache.flink.runtime.instance.InstanceConnectionInfo extends Object implements Serializable
  
  serialVersionUID:
  
  -8254407801276350716L
  - Serialized Fields
    - inetAddress
```
InetAddress inetAddress
```
      The network address the instance's task manager binds its sockets to.
    - dataPort
```
int dataPort
```
      The port the instance's task manager expects to receive transfer envelopes on.
    - fqdnHostName
```
String fqdnHostName
```
      The fully qualified host name of the instance.
    - hostName
```
String hostName
```
      The hostname, derived from the fully qualified host name.
- Class org.apache.flink.runtime.instance.InstanceDiedException extends Exception implements Serializable
  
  serialVersionUID:
  
  -4917918318403135745L
  - Serialized Fields
    - instance
```
Instance instance
```
- Class org.apache.flink.runtime.instance.InstanceID extends org.apache.flink.util.AbstractID implements Serializable
  
  serialVersionUID:
  
  1L
Package org.apache.flink.runtime.io.disk.iomanager
- Class org.apache.flink.runtime.io.disk.iomanager.RequestQueue extends LinkedBlockingQueue<E> implements Serializable
  
  serialVersionUID:
  
  3804115535778471680L
  - Serialized Fields
    - closed
```
boolean closed
```
      Flag marking this queue as closed.
Package org.apache.flink.runtime.io.network
- Class org.apache.flink.runtime.io.network.ConnectionID extends Object implements Serializable
  - Serialized Fields
    - address
```
InetSocketAddress address
```
    - connectionIndex
```
int connectionIndex
```
Package org.apache.flink.runtime.io.network.netty.exception
- Class org.apache.flink.runtime.io.network.netty.exception.LocalTransportException extends TransportException implements Serializable
  
  serialVersionUID:
  
  2366708881288640674L
- Class org.apache.flink.runtime.io.network.netty.exception.RemoteTransportException extends TransportException implements Serializable
  
  serialVersionUID:
  
  4373615529545893089L
- Class org.apache.flink.runtime.io.network.netty.exception.TransportException extends IOException implements Serializable
  
  serialVersionUID:
  
  3637820720589866570L
  - Serialized Fields
    - address
```
SocketAddress address
```
Package org.apache.flink.runtime.io.network.partition
- Class org.apache.flink.runtime.io.network.partition.PartitionNotFoundException extends IOException implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - partitionId
```
ResultPartitionID partitionId
```
- Class org.apache.flink.runtime.io.network.partition.ProducerFailedException extends CancelTaskException implements Serializable
  
  serialVersionUID:
  
  -1555492656299526395L
  - Serialized Fields
    - cause
```
Throwable cause
```
- Class org.apache.flink.runtime.io.network.partition.ResultPartitionID extends Object implements Serializable
  - Serialized Fields
    - partitionId
```
IntermediateResultPartitionID partitionId
```
    - producerId
```
ExecutionAttemptID producerId
```
Package org.apache.flink.runtime.io.network.partition.consumer
- Class org.apache.flink.runtime.io.network.partition.consumer.InputChannelID extends org.apache.flink.util.AbstractID implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.runtime.io.network.partition.consumer.RemoteInputChannel.BufferReorderingException extends IOException implements Serializable
  
  serialVersionUID:
  
  -888282210356266816L
  - Serialized Fields
    - expectedSequenceNumber
```
int expectedSequenceNumber
```
    - actualSequenceNumber
```
int actualSequenceNumber
```
Package org.apache.flink.runtime.iterative.convergence
- Class org.apache.flink.runtime.iterative.convergence.WorksetEmptyConvergenceCriterion extends Object implements Serializable
  
  serialVersionUID:
  
  1L
Package org.apache.flink.runtime.jobgraph
- Class org.apache.flink.runtime.jobgraph.InputFormatVertex extends JobVertex implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - formatDescription
```
String formatDescription
```
- Class org.apache.flink.runtime.jobgraph.IntermediateDataSet extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - id
```
IntermediateDataSetID id
```
    - producer
```
JobVertex producer
```
    - consumers
```
List<E> consumers
```
    - resultType
```
ResultPartitionType resultType
```
- Class org.apache.flink.runtime.jobgraph.IntermediateDataSetID extends org.apache.flink.util.AbstractID implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.runtime.jobgraph.IntermediateResultPartitionID extends org.apache.flink.util.AbstractID implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.runtime.jobgraph.JobEdge extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - target
```
JobVertex target
```
      The vertex connected to this edge.
    - distributionPattern
```
DistributionPattern distributionPattern
```
      The distribution pattern that should be used for this job edge.
    - source
```
IntermediateDataSet source
```
      The data set at the source of the edge, may be null if the edge is not yet connected
    - sourceId
```
IntermediateDataSetID sourceId
```
      The id of the source intermediate data set
- Class org.apache.flink.runtime.jobgraph.JobGraph extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - taskVertices
```
Map<K,V> taskVertices
```
      List of task vertices included in this job graph.
    - jobConfiguration
```
org.apache.flink.configuration.Configuration jobConfiguration
```
      The job configuration attached to this job.
    - userJars
```
List<E> userJars
```
      Set of JAR files required to run this job.
    - userJarBlobKeys
```
List<E> userJarBlobKeys
```
      Set of blob keys identifying the JAR files required to run this job.
    - jobID
```
org.apache.flink.api.common.JobID jobID
```
      ID of this job.
    - jobName
```
String jobName
```
      Name of this job.
    - numExecutionRetries
```
int numExecutionRetries
```
      The number of times that failed tasks should be re-executed
    - allowQueuedScheduling
```
boolean allowQueuedScheduling
```
      flag to enable queued scheduling
    - scheduleMode
```
ScheduleMode scheduleMode
```
      The mode in which the job is scheduled
    - snapshotSettings
```
JobSnapshottingSettings snapshotSettings
```
      The settings for asynchronous snapshotting
- Class org.apache.flink.runtime.jobgraph.JobVertex extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - id
```
JobVertexID id
```
      The ID of the vertex.
    - results
```
ArrayList<E> results
```
      List of produced data sets, one per writer
    - inputs
```
ArrayList<E> inputs
```
      List of edges with incoming data. One per Reader.
    - parallelism
```
int parallelism
```
      Number of subtasks to split this task into at runtime.
    - configuration
```
org.apache.flink.configuration.Configuration configuration
```
      Custom configuration passed to the assigned task at runtime.
    - invokableClassName
```
String invokableClassName
```
      The class of the invokable.
    - inputSplitSource
```
org.apache.flink.core.io.InputSplitSource<T extends org.apache.flink.core.io.InputSplit> inputSplitSource
```
      Optionally, a source of input splits
    - name
```
String name
```
      The name of the vertex
    - slotSharingGroup
```
SlotSharingGroup slotSharingGroup
```
      Optionally, a sharing group that allows subtasks from different job vertices to run concurrently in one slot
    - coLocationGroup
```
CoLocationGroup coLocationGroup
```
      The group inside which the vertex subtasks share slots
- Class org.apache.flink.runtime.jobgraph.JobVertexID extends org.apache.flink.util.AbstractID implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.runtime.jobgraph.OutputFormatVertex extends JobVertex implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - formatDescription
```
String formatDescription
```
Package org.apache.flink.runtime.jobgraph.tasks
- Class org.apache.flink.runtime.jobgraph.tasks.JobSnapshottingSettings extends Object implements Serializable
  
  serialVersionUID:
  
  -2593319571078198180L
  - Serialized Fields
    - verticesToTrigger
```
List<E> verticesToTrigger
```
    - verticesToAcknowledge
```
List<E> verticesToAcknowledge
```
    - verticesToConfirm
```
List<E> verticesToConfirm
```
    - checkpointInterval
```
long checkpointInterval
```
    - checkpointTimeout
```
long checkpointTimeout
```
Package org.apache.flink.runtime.jobmanager.scheduler
- Class org.apache.flink.runtime.jobmanager.scheduler.CoLocationGroup extends Object implements Serializable
  
  serialVersionUID:
  
  -2605819490401895297L
  - Serialized Fields
    - id
```
org.apache.flink.util.AbstractID id
```
      The ID that describes the slot co-location-constraint as a group
    - vertices
```
List<E> vertices
```
      The vertices participating in the co-location group
- Class org.apache.flink.runtime.jobmanager.scheduler.NoResourceAvailableException extends JobException implements Serializable
  
  serialVersionUID:
  
  -2249953165298717803L
- Class org.apache.flink.runtime.jobmanager.scheduler.ResourceId extends org.apache.flink.util.AbstractID implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.runtime.jobmanager.scheduler.SlotSharingGroup extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - ids
```
Set<E> ids
```
Package org.apache.flink.runtime.jobmanager.web
- Class org.apache.flink.runtime.jobmanager.web.JobManagerInfoServlet extends javax.servlet.http.HttpServlet implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - jobmanager
```
akka.actor.ActorRef jobmanager
```
      Underlying JobManager
    - archive
```
akka.actor.ActorRef archive
```
    - timeout
```
scala.concurrent.duration.FiniteDuration timeout
```
- Class org.apache.flink.runtime.jobmanager.web.LogfileInfoServlet extends javax.servlet.http.HttpServlet implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - logDirs
```
File[] logDirs
```
- Class org.apache.flink.runtime.jobmanager.web.MenuServlet extends javax.servlet.http.HttpServlet implements Serializable
  
  serialVersionUID:
  
  117543213991787547L
- Class org.apache.flink.runtime.jobmanager.web.SetupInfoServlet extends javax.servlet.http.HttpServlet implements Serializable
  
  serialVersionUID:
  
  3704963598772630435L
  - Serialized Fields
    - configuration
```
org.apache.flink.configuration.Configuration configuration
```
    - jobmanager
```
akka.actor.ActorRef jobmanager
```
    - timeout
```
scala.concurrent.duration.FiniteDuration timeout
```
Package org.apache.flink.runtime.memorymanager
- Class org.apache.flink.runtime.memorymanager.MemoryAllocationException extends Exception implements Serializable
  
  serialVersionUID:
  
  -403983866457947012L
Package org.apache.flink.runtime.messages
- Class org.apache.flink.runtime.messages.ArchiveMessages.ArchivedJob extends Object implements Serializable
  - Serialized Fields
    - job
```
scala.Option<A> job
```
- Class org.apache.flink.runtime.messages.ArchiveMessages.ArchivedJob$ extends scala.runtime.AbstractFunction1<scala.Option<ExecutionGraph>,org.apache.flink.runtime.messages.ArchiveMessages.ArchivedJob> implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.runtime.messages.ArchiveMessages.ArchivedJobs extends Object implements Serializable
  - Serialized Fields
    - jobs
```
scala.collection.Iterable<A> jobs
```
- Class org.apache.flink.runtime.messages.ArchiveMessages.ArchivedJobs$ extends scala.runtime.AbstractFunction1<scala.collection.Iterable<ExecutionGraph>,org.apache.flink.runtime.messages.ArchiveMessages.ArchivedJobs> implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.runtime.messages.ArchiveMessages.ArchiveExecutionGraph extends Object implements Serializable
  - Serialized Fields
    - jobID
```
org.apache.flink.api.common.JobID jobID
```
    - graph
```
ExecutionGraph graph
```
- Class org.apache.flink.runtime.messages.ArchiveMessages.ArchiveExecutionGraph$ extends scala.runtime.AbstractFunction2<org.apache.flink.api.common.JobID,ExecutionGraph,org.apache.flink.runtime.messages.ArchiveMessages.ArchiveExecutionGraph> implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.runtime.messages.ArchiveMessages.RequestArchivedJob extends Object implements Serializable
  - Serialized Fields
    - jobID
```
org.apache.flink.api.common.JobID jobID
```
- Class org.apache.flink.runtime.messages.ArchiveMessages.RequestArchivedJob$ extends scala.runtime.AbstractFunction1<org.apache.flink.api.common.JobID,org.apache.flink.runtime.messages.ArchiveMessages.RequestArchivedJob> implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.runtime.messages.ArchiveMessages.RequestArchivedJobs$ extends Object implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.runtime.messages.ArchiveMessages.RequestJobCounts$ extends Object implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.runtime.messages.ExecutionGraphMessages.ExecutionStateChanged extends Object implements Serializable
  - Serialized Fields
    - jobID
```
org.apache.flink.api.common.JobID jobID
```
    - vertexID
```
JobVertexID vertexID
```
    - taskName
```
String taskName
```
    - totalNumberOfSubTasks
```
int totalNumberOfSubTasks
```
    - subtaskIndex
```
int subtaskIndex
```
    - executionID
```
ExecutionAttemptID executionID
```
    - newExecutionState
```
ExecutionState newExecutionState
```
    - timestamp
```
long timestamp
```
    - optionalMessage
```
String optionalMessage
```
- Class org.apache.flink.runtime.messages.ExecutionGraphMessages.ExecutionStateChanged$ extends scala.runtime.AbstractFunction9<org.apache.flink.api.common.JobID,JobVertexID,String,Object,Object,ExecutionAttemptID,ExecutionState,Object,String,org.apache.flink.runtime.messages.ExecutionGraphMessages.ExecutionStateChanged> implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.runtime.messages.ExecutionGraphMessages.JobStatusChanged extends Object implements Serializable
  - Serialized Fields
    - jobID
```
org.apache.flink.api.common.JobID jobID
```
    - newJobStatus
```
JobStatus newJobStatus
```
    - timestamp
```
long timestamp
```
    - error
```
Throwable error
```
- Class org.apache.flink.runtime.messages.ExecutionGraphMessages.JobStatusChanged$ extends scala.runtime.AbstractFunction4<org.apache.flink.api.common.JobID,JobStatus,Object,Throwable,org.apache.flink.runtime.messages.ExecutionGraphMessages.JobStatusChanged> implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.runtime.messages.JobClientMessages.SubmitJobAndWait extends Object implements Serializable
  - Serialized Fields
    - jobGraph
```
JobGraph jobGraph
```
- Class org.apache.flink.runtime.messages.JobClientMessages.SubmitJobAndWait$ extends scala.runtime.AbstractFunction1<JobGraph,org.apache.flink.runtime.messages.JobClientMessages.SubmitJobAndWait> implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.runtime.messages.JobClientMessages.SubmitJobDetached extends Object implements Serializable
  - Serialized Fields
    - jobGraph
```
JobGraph jobGraph
```
- Class org.apache.flink.runtime.messages.JobClientMessages.SubmitJobDetached$ extends scala.runtime.AbstractFunction1<JobGraph,org.apache.flink.runtime.messages.JobClientMessages.SubmitJobDetached> implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.runtime.messages.JobManagerMessages.CancelJob extends Object implements Serializable
  - Serialized Fields
    - jobID
```
org.apache.flink.api.common.JobID jobID
```
- Class org.apache.flink.runtime.messages.JobManagerMessages.CancelJob$ extends scala.runtime.AbstractFunction1<org.apache.flink.api.common.JobID,org.apache.flink.runtime.messages.JobManagerMessages.CancelJob> implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.runtime.messages.JobManagerMessages.CancellationFailure extends Object implements Serializable
  - Serialized Fields
    - jobID
```
org.apache.flink.api.common.JobID jobID
```
    - cause
```
Throwable cause
```
- Class org.apache.flink.runtime.messages.JobManagerMessages.CancellationFailure$ extends scala.runtime.AbstractFunction2<org.apache.flink.api.common.JobID,Throwable,org.apache.flink.runtime.messages.JobManagerMessages.CancellationFailure> implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.runtime.messages.JobManagerMessages.CancellationSuccess extends Object implements Serializable
  - Serialized Fields
    - jobID
```
org.apache.flink.api.common.JobID jobID
```
- Class org.apache.flink.runtime.messages.JobManagerMessages.CancellationSuccess$ extends scala.runtime.AbstractFunction1<org.apache.flink.api.common.JobID,org.apache.flink.runtime.messages.JobManagerMessages.CancellationSuccess> implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.runtime.messages.JobManagerMessages.ConsumerNotificationResult extends Object implements Serializable
  - Serialized Fields
    - success
```
boolean success
```
    - error
```
scala.Option<A> error
```
- Class org.apache.flink.runtime.messages.JobManagerMessages.ConsumerNotificationResult$ extends scala.runtime.AbstractFunction2<Object,scala.Option<Throwable>,org.apache.flink.runtime.messages.JobManagerMessages.ConsumerNotificationResult> implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.runtime.messages.JobManagerMessages.CurrentJobStatus extends Object implements Serializable
  - Serialized Fields
    - jobID
```
org.apache.flink.api.common.JobID jobID
```
    - status
```
JobStatus status
```
- Class org.apache.flink.runtime.messages.JobManagerMessages.CurrentJobStatus$ extends scala.runtime.AbstractFunction2<org.apache.flink.api.common.JobID,JobStatus,org.apache.flink.runtime.messages.JobManagerMessages.CurrentJobStatus> implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.runtime.messages.JobManagerMessages.JobFound extends Object implements Serializable
  - Serialized Fields
    - jobID
```
org.apache.flink.api.common.JobID jobID
```
    - executionGraph
```
ExecutionGraph executionGraph
```
- Class org.apache.flink.runtime.messages.JobManagerMessages.JobFound$ extends scala.runtime.AbstractFunction2<org.apache.flink.api.common.JobID,ExecutionGraph,org.apache.flink.runtime.messages.JobManagerMessages.JobFound> implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.runtime.messages.JobManagerMessages.JobManagerStatusAlive$ extends Object implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.runtime.messages.JobManagerMessages.JobNotFound extends Object implements Serializable
  - Serialized Fields
    - jobID
```
org.apache.flink.api.common.JobID jobID
```
- Class org.apache.flink.runtime.messages.JobManagerMessages.JobNotFound$ extends scala.runtime.AbstractFunction1<org.apache.flink.api.common.JobID,org.apache.flink.runtime.messages.JobManagerMessages.JobNotFound> implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.runtime.messages.JobManagerMessages.JobResultSuccess extends Object implements Serializable
  - Serialized Fields
    - result
```
SerializedJobExecutionResult result
```
- Class org.apache.flink.runtime.messages.JobManagerMessages.JobResultSuccess$ extends scala.runtime.AbstractFunction1<SerializedJobExecutionResult,org.apache.flink.runtime.messages.JobManagerMessages.JobResultSuccess> implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.runtime.messages.JobManagerMessages.NextInputSplit extends Object implements Serializable
  - Serialized Fields
    - splitData
```
byte[] splitData
```
- Class org.apache.flink.runtime.messages.JobManagerMessages.NextInputSplit$ extends scala.runtime.AbstractFunction1<byte[],org.apache.flink.runtime.messages.JobManagerMessages.NextInputSplit> implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.runtime.messages.JobManagerMessages.RegisteredTaskManagers extends Object implements Serializable
  - Serialized Fields
    - taskManagers
```
scala.collection.Iterable<A> taskManagers
```
- Class org.apache.flink.runtime.messages.JobManagerMessages.RegisteredTaskManagers$ extends scala.runtime.AbstractFunction1<scala.collection.Iterable<Instance>,org.apache.flink.runtime.messages.JobManagerMessages.RegisteredTaskManagers> implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.runtime.messages.JobManagerMessages.RequestBlobManagerPort$ extends Object implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.runtime.messages.JobManagerMessages.RequestJob extends Object implements Serializable
  - Serialized Fields
    - jobID
```
org.apache.flink.api.common.JobID jobID
```
- Class org.apache.flink.runtime.messages.JobManagerMessages.RequestJob$ extends scala.runtime.AbstractFunction1<org.apache.flink.api.common.JobID,org.apache.flink.runtime.messages.JobManagerMessages.RequestJob> implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.runtime.messages.JobManagerMessages.RequestJobManagerStatus$ extends Object implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.runtime.messages.JobManagerMessages.RequestJobStatus extends Object implements Serializable
  - Serialized Fields
    - jobID
```
org.apache.flink.api.common.JobID jobID
```
- Class org.apache.flink.runtime.messages.JobManagerMessages.RequestJobStatus$ extends scala.runtime.AbstractFunction1<org.apache.flink.api.common.JobID,org.apache.flink.runtime.messages.JobManagerMessages.RequestJobStatus> implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.runtime.messages.JobManagerMessages.RequestNextInputSplit extends Object implements Serializable
  - Serialized Fields
    - jobID
```
org.apache.flink.api.common.JobID jobID
```
    - vertexID
```
JobVertexID vertexID
```
    - executionAttempt
```
ExecutionAttemptID executionAttempt
```
- Class org.apache.flink.runtime.messages.JobManagerMessages.RequestNextInputSplit$ extends scala.runtime.AbstractFunction3<org.apache.flink.api.common.JobID,JobVertexID,ExecutionAttemptID,org.apache.flink.runtime.messages.JobManagerMessages.RequestNextInputSplit> implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.runtime.messages.JobManagerMessages.RequestNumberRegisteredTaskManager$ extends Object implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.runtime.messages.JobManagerMessages.RequestPartitionState extends Object implements Serializable
  - Serialized Fields
    - jobId
```
org.apache.flink.api.common.JobID jobId
```
    - partitionId
```
ResultPartitionID partitionId
```
    - taskExecutionId
```
ExecutionAttemptID taskExecutionId
```
    - taskResultId
```
IntermediateDataSetID taskResultId
```
- Class org.apache.flink.runtime.messages.JobManagerMessages.RequestPartitionState$ extends scala.runtime.AbstractFunction4<org.apache.flink.api.common.JobID,ResultPartitionID,ExecutionAttemptID,IntermediateDataSetID,org.apache.flink.runtime.messages.JobManagerMessages.RequestPartitionState> implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.runtime.messages.JobManagerMessages.RequestRegisteredTaskManagers$ extends Object implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.runtime.messages.JobManagerMessages.RequestRunningJobs$ extends Object implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.runtime.messages.JobManagerMessages.RequestRunningJobsStatus$ extends Object implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.runtime.messages.JobManagerMessages.RequestStackTrace extends Object implements Serializable
  - Serialized Fields
    - instanceID
```
InstanceID instanceID
```
- Class org.apache.flink.runtime.messages.JobManagerMessages.RequestStackTrace$ extends scala.runtime.AbstractFunction1<InstanceID,org.apache.flink.runtime.messages.JobManagerMessages.RequestStackTrace> implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.runtime.messages.JobManagerMessages.RequestTotalNumberOfSlots$ extends Object implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.runtime.messages.JobManagerMessages.RunningJobs extends Object implements Serializable
  - Serialized Fields
    - runningJobs
```
scala.collection.Iterable<A> runningJobs
```
- Class org.apache.flink.runtime.messages.JobManagerMessages.RunningJobs$ extends scala.runtime.AbstractFunction1<scala.collection.Iterable<ExecutionGraph>,org.apache.flink.runtime.messages.JobManagerMessages.RunningJobs> implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.runtime.messages.JobManagerMessages.RunningJobsStatus extends Object implements Serializable
  - Serialized Fields
    - runningJobs
```
scala.collection.Iterable<A> runningJobs
```
- Class org.apache.flink.runtime.messages.JobManagerMessages.RunningJobsStatus$ extends scala.runtime.AbstractFunction1<scala.collection.Iterable<JobStatusMessage>,org.apache.flink.runtime.messages.JobManagerMessages.RunningJobsStatus> implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.runtime.messages.JobManagerMessages.ScheduleOrUpdateConsumers extends Object implements Serializable
  - Serialized Fields
    - jobId
```
org.apache.flink.api.common.JobID jobId
```
    - partitionId
```
ResultPartitionID partitionId
```
- Class org.apache.flink.runtime.messages.JobManagerMessages.ScheduleOrUpdateConsumers$ extends scala.runtime.AbstractFunction2<org.apache.flink.api.common.JobID,ResultPartitionID,org.apache.flink.runtime.messages.JobManagerMessages.ScheduleOrUpdateConsumers> implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.runtime.messages.JobManagerMessages.SubmitJob extends Object implements Serializable
  - Serialized Fields
    - jobGraph
```
JobGraph jobGraph
```
    - registerForEvents
```
boolean registerForEvents
```
- Class org.apache.flink.runtime.messages.JobManagerMessages.SubmitJob$ extends scala.runtime.AbstractFunction2<JobGraph,Object,org.apache.flink.runtime.messages.JobManagerMessages.SubmitJob> implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.runtime.messages.Messages.Acknowledge$ extends Object implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.runtime.messages.Messages.Disconnect extends Object implements Serializable
  - Serialized Fields
    - reason
```
String reason
```
- Class org.apache.flink.runtime.messages.Messages.Disconnect$ extends scala.runtime.AbstractFunction1<String,org.apache.flink.runtime.messages.Messages.Disconnect> implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.runtime.messages.RegistrationMessages.AcknowledgeRegistration extends Object implements Serializable
  - Serialized Fields
    - jobManager
```
akka.actor.ActorRef jobManager
```
    - instanceID
```
InstanceID instanceID
```
    - blobPort
```
int blobPort
```
- Class org.apache.flink.runtime.messages.RegistrationMessages.AcknowledgeRegistration$ extends scala.runtime.AbstractFunction3<akka.actor.ActorRef,InstanceID,Object,org.apache.flink.runtime.messages.RegistrationMessages.AcknowledgeRegistration> implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.runtime.messages.RegistrationMessages.AlreadyRegistered extends Object implements Serializable
  - Serialized Fields
    - jobManager
```
akka.actor.ActorRef jobManager
```
    - instanceID
```
InstanceID instanceID
```
    - blobPort
```
int blobPort
```
- Class org.apache.flink.runtime.messages.RegistrationMessages.AlreadyRegistered$ extends scala.runtime.AbstractFunction3<akka.actor.ActorRef,InstanceID,Object,org.apache.flink.runtime.messages.RegistrationMessages.AlreadyRegistered> implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.runtime.messages.RegistrationMessages.RefuseRegistration extends Object implements Serializable
  - Serialized Fields
    - reason
```
String reason
```
- Class org.apache.flink.runtime.messages.RegistrationMessages.RefuseRegistration$ extends scala.runtime.AbstractFunction1<String,org.apache.flink.runtime.messages.RegistrationMessages.RefuseRegistration> implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.runtime.messages.RegistrationMessages.RegisterTaskManager extends Object implements Serializable
  - Serialized Fields
    - taskManager
```
akka.actor.ActorRef taskManager
```
    - connectionInfo
```
InstanceConnectionInfo connectionInfo
```
    - resources
```
HardwareDescription resources
```
    - numberOfSlots
```
int numberOfSlots
```
- Class org.apache.flink.runtime.messages.RegistrationMessages.RegisterTaskManager$ extends scala.runtime.AbstractFunction4<akka.actor.ActorRef,InstanceConnectionInfo,HardwareDescription,Object,org.apache.flink.runtime.messages.RegistrationMessages.RegisterTaskManager> implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.runtime.messages.RegistrationMessages.TriggerTaskManagerRegistration extends Object implements Serializable
  - Serialized Fields
    - jobManagerAkkaURL
```
String jobManagerAkkaURL
```
    - timeout
```
scala.concurrent.duration.FiniteDuration timeout
```
    - deadline
```
scala.Option<A> deadline
```
    - attempt
```
int attempt
```
- Class org.apache.flink.runtime.messages.RegistrationMessages.TriggerTaskManagerRegistration$ extends scala.runtime.AbstractFunction4<String,scala.concurrent.duration.FiniteDuration,scala.Option<scala.concurrent.duration.Deadline>,Object,org.apache.flink.runtime.messages.RegistrationMessages.TriggerTaskManagerRegistration> implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.runtime.messages.TaskManagerMessages.FatalError extends Object implements Serializable
  - Serialized Fields
    - description
```
String description
```
    - cause
```
Throwable cause
```
- Class org.apache.flink.runtime.messages.TaskManagerMessages.FatalError$ extends scala.runtime.AbstractFunction2<String,Throwable,org.apache.flink.runtime.messages.TaskManagerMessages.FatalError> implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.runtime.messages.TaskManagerMessages.Heartbeat extends Object implements Serializable
  - Serialized Fields
    - instanceID
```
InstanceID instanceID
```
    - metricsReport
```
byte[] metricsReport
```
- Class org.apache.flink.runtime.messages.TaskManagerMessages.Heartbeat$ extends scala.runtime.AbstractFunction2<InstanceID,byte[],org.apache.flink.runtime.messages.TaskManagerMessages.Heartbeat> implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.runtime.messages.TaskManagerMessages.NotifyWhenRegisteredAtJobManager$ extends Object implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.runtime.messages.TaskManagerMessages.RegisteredAtJobManager$ extends Object implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.runtime.messages.TaskManagerMessages.SendHeartbeat$ extends Object implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.runtime.messages.TaskManagerMessages.SendStackTrace$ extends Object implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.runtime.messages.TaskManagerMessages.StackTrace extends Object implements Serializable
  - Serialized Fields
    - instanceID
```
InstanceID instanceID
```
    - stackTrace
```
String stackTrace
```
- Class org.apache.flink.runtime.messages.TaskManagerMessages.StackTrace$ extends scala.runtime.AbstractFunction2<InstanceID,String,org.apache.flink.runtime.messages.TaskManagerMessages.StackTrace> implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.runtime.messages.TaskMessages.CancelTask extends Object implements Serializable
  - Serialized Fields
    - attemptID
```
ExecutionAttemptID attemptID
```
- Class org.apache.flink.runtime.messages.TaskMessages.CancelTask$ extends scala.runtime.AbstractFunction1<ExecutionAttemptID,org.apache.flink.runtime.messages.TaskMessages.CancelTask> implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.runtime.messages.TaskMessages.FailIntermediateResultPartitions extends Object implements Serializable
  - Serialized Fields
    - executionID
```
ExecutionAttemptID executionID
```
- Class org.apache.flink.runtime.messages.TaskMessages.FailIntermediateResultPartitions$ extends scala.runtime.AbstractFunction1<ExecutionAttemptID,org.apache.flink.runtime.messages.TaskMessages.FailIntermediateResultPartitions> implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.runtime.messages.TaskMessages.FailTask extends Object implements Serializable
  - Serialized Fields
    - executionID
```
ExecutionAttemptID executionID
```
    - cause
```
Throwable cause
```
- Class org.apache.flink.runtime.messages.TaskMessages.FailTask$ extends scala.runtime.AbstractFunction2<ExecutionAttemptID,Throwable,org.apache.flink.runtime.messages.TaskMessages.FailTask> implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.runtime.messages.TaskMessages.PartitionState extends Object implements Serializable
  - Serialized Fields
    - taskExecutionId
```
ExecutionAttemptID taskExecutionId
```
    - taskResultId
```
IntermediateDataSetID taskResultId
```
    - partitionId
```
IntermediateResultPartitionID partitionId
```
    - state
```
ExecutionState state
```
- Class org.apache.flink.runtime.messages.TaskMessages.PartitionState$ extends scala.runtime.AbstractFunction4<ExecutionAttemptID,IntermediateDataSetID,IntermediateResultPartitionID,ExecutionState,org.apache.flink.runtime.messages.TaskMessages.PartitionState> implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.runtime.messages.TaskMessages.SubmitTask extends Object implements Serializable
  - Serialized Fields
    - tasks
```
TaskDeploymentDescriptor tasks
```
- Class org.apache.flink.runtime.messages.TaskMessages.SubmitTask$ extends scala.runtime.AbstractFunction1<TaskDeploymentDescriptor,org.apache.flink.runtime.messages.TaskMessages.SubmitTask> implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.runtime.messages.TaskMessages.TaskInFinalState extends Object implements Serializable
  - Serialized Fields
    - executionID
```
ExecutionAttemptID executionID
```
- Class org.apache.flink.runtime.messages.TaskMessages.TaskInFinalState$ extends scala.runtime.AbstractFunction1<ExecutionAttemptID,org.apache.flink.runtime.messages.TaskMessages.TaskInFinalState> implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.runtime.messages.TaskMessages.TaskOperationResult extends Object implements Serializable
  - Serialized Fields
    - executionID
```
ExecutionAttemptID executionID
```
    - success
```
boolean success
```
    - description
```
String description
```
- Class org.apache.flink.runtime.messages.TaskMessages.TaskOperationResult$ extends scala.runtime.AbstractFunction3<ExecutionAttemptID,Object,String,org.apache.flink.runtime.messages.TaskMessages.TaskOperationResult> implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.runtime.messages.TaskMessages.UpdateTaskExecutionState extends Object implements Serializable
  - Serialized Fields
    - taskExecutionState
```
TaskExecutionState taskExecutionState
```
- Class org.apache.flink.runtime.messages.TaskMessages.UpdateTaskExecutionState$ extends scala.runtime.AbstractFunction1<TaskExecutionState,org.apache.flink.runtime.messages.TaskMessages.UpdateTaskExecutionState> implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.runtime.messages.TaskMessages.UpdateTaskMultiplePartitionInfos extends org.apache.flink.runtime.messages.TaskMessages.UpdatePartitionInfo implements Serializable
  - Serialized Fields
    - executionID
```
ExecutionAttemptID executionID
```
    - partitionInfos
```
scala.collection.Seq<A> partitionInfos
```
- Class org.apache.flink.runtime.messages.TaskMessages.UpdateTaskMultiplePartitionInfos$ extends scala.runtime.AbstractFunction2<ExecutionAttemptID,scala.collection.Seq<scala.Tuple2<IntermediateDataSetID,InputChannelDeploymentDescriptor>>,org.apache.flink.runtime.messages.TaskMessages.UpdateTaskMultiplePartitionInfos> implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.runtime.messages.TaskMessages.UpdateTaskSinglePartitionInfo extends org.apache.flink.runtime.messages.TaskMessages.UpdatePartitionInfo implements Serializable
  - Serialized Fields
    - executionID
```
ExecutionAttemptID executionID
```
    - resultId
```
IntermediateDataSetID resultId
```
    - partitionInfo
```
InputChannelDeploymentDescriptor partitionInfo
```
- Class org.apache.flink.runtime.messages.TaskMessages.UpdateTaskSinglePartitionInfo$ extends scala.runtime.AbstractFunction3<ExecutionAttemptID,IntermediateDataSetID,InputChannelDeploymentDescriptor,org.apache.flink.runtime.messages.TaskMessages.UpdateTaskSinglePartitionInfo> implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
Package org.apache.flink.runtime.messages.checkpoint
- Class org.apache.flink.runtime.messages.checkpoint.AbstractCheckpointMessage extends Object implements Serializable
  
  serialVersionUID:
  
  186780414819428178L
  - Serialized Fields
    - job
```
org.apache.flink.api.common.JobID job
```
      The job to which this message belongs
    - taskExecutionId
```
ExecutionAttemptID taskExecutionId
```
      The task execution that is source/target of the checkpoint message
    - checkpointId
```
long checkpointId
```
      The ID of the checkpoint that this message coordinates
- Class org.apache.flink.runtime.messages.checkpoint.AcknowledgeCheckpoint extends AbstractCheckpointMessage implements Serializable
  
  serialVersionUID:
  
  -7606214777192401493L
  - Serialized Fields
    - state
```
SerializedValue<T> state
```
- Class org.apache.flink.runtime.messages.checkpoint.ConfirmCheckpoint extends AbstractCheckpointMessage implements Serializable
  
  serialVersionUID:
  
  2094094662279578953L
  - Serialized Fields
    - timestamp
```
long timestamp
```
      The timestamp associated with the checkpoint
- Class org.apache.flink.runtime.messages.checkpoint.TriggerCheckpoint extends AbstractCheckpointMessage implements Serializable
  
  serialVersionUID:
  
  2094094662279578953L
  - Serialized Fields
    - timestamp
```
long timestamp
```
      The timestamp associated with the checkpoint
Package org.apache.flink.runtime.operators.chaining
- Class org.apache.flink.runtime.operators.chaining.ExceptionInChainedStubException extends RuntimeException implements Serializable
  
  serialVersionUID:
  
  -7966910518892776903L
  - Serialized Fields
    - taskName
```
String taskName
```
    - exception
```
Exception exception
```
Package org.apache.flink.runtime.operators.util
- Class org.apache.flink.runtime.operators.util.CorruptConfigurationException extends RuntimeException implements Serializable
  
  serialVersionUID:
  
  854450995262666207L
- Class org.apache.flink.runtime.operators.util.TaskConfig extends Object implements Serializable
  - Serialized Fields
    - config
```
org.apache.flink.configuration.Configuration config
```
- Class org.apache.flink.runtime.operators.util.TaskConfig.DelegatingConfiguration extends org.apache.flink.configuration.Configuration implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - backingConfig
```
org.apache.flink.configuration.Configuration backingConfig
```
    - prefix
```
String prefix
```
Package org.apache.flink.runtime.state
- Class org.apache.flink.runtime.state.ByteStreamStateHandle extends Object implements Serializable
  
  serialVersionUID:
  
  -962025800339325828L
  - Serialization Methods
    - writeObject
```
private void writeObject(ObjectOutputStream oos)
                  throws Exception
```
      Throws:
      
      Exception
- Class org.apache.flink.runtime.state.FileStateHandle extends ByteStreamStateHandle implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - pathString
```
String pathString
```
- Class org.apache.flink.runtime.state.LocalStateHandle extends Object implements Serializable
  
  serialVersionUID:
  
  2093619217898039610L
  - Serialized Fields
    - state
```
Serializable state
```
Package org.apache.flink.runtime.taskmanager
- Class org.apache.flink.runtime.taskmanager.NetworkEnvironmentConfiguration extends Object implements Serializable
  - Serialized Fields
    - numNetworkBuffers
```
int numNetworkBuffers
```
    - networkBufferSize
```
int networkBufferSize
```
    - ioMode
```
IOManager.IOMode ioMode
```
    - nettyConfig
```
scala.Option<A> nettyConfig
```
    - partitionRequestInitialAndMaxBackoff
```
scala.Tuple2<T1,T2> partitionRequestInitialAndMaxBackoff
```
- Class org.apache.flink.runtime.taskmanager.NetworkEnvironmentConfiguration$ extends scala.runtime.AbstractFunction5<Object,Object,IOManager.IOMode,scala.Option<NettyConfig>,scala.Tuple2<Integer,Integer>,org.apache.flink.runtime.taskmanager.NetworkEnvironmentConfiguration> implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
- Class org.apache.flink.runtime.taskmanager.TaskExecutionState extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - jobID
```
org.apache.flink.api.common.JobID jobID
```
    - executionId
```
ExecutionAttemptID executionId
```
    - executionState
```
ExecutionState executionState
```
    - serializedError
```
byte[] serializedError
```
- Class org.apache.flink.runtime.taskmanager.TaskManagerConfiguration extends Object implements Serializable
  - Serialized Fields
    - tmpDirPaths
```
String[] tmpDirPaths
```
    - cleanupInterval
```
long cleanupInterval
```
    - timeout
```
scala.concurrent.duration.FiniteDuration timeout
```
    - maxRegistrationDuration
```
scala.Option<A> maxRegistrationDuration
```
    - numberOfSlots
```
int numberOfSlots
```
    - configuration
```
org.apache.flink.configuration.Configuration configuration
```
- Class org.apache.flink.runtime.taskmanager.TaskManagerConfiguration$ extends scala.runtime.AbstractFunction6<String[],Object,scala.concurrent.duration.FiniteDuration,scala.Option<scala.concurrent.duration.FiniteDuration>,Object,org.apache.flink.configuration.Configuration,org.apache.flink.runtime.taskmanager.TaskManagerConfiguration> implements Serializable
  - Serialization Methods
    - readResolve
```
private Object readResolve()
```
Package org.apache.flink.runtime.util
- Class org.apache.flink.runtime.util.SerializableArrayList extends ArrayList<E extends org.apache.flink.core.io.IOReadableWritable> implements Serializable
  
  serialVersionUID:
  
  8196856588290198537L
- Class org.apache.flink.runtime.util.SerializableHashMap extends HashMap<K extends org.apache.flink.core.io.IOReadableWritable,V extends org.apache.flink.core.io.IOReadableWritable> implements Serializable
  
  serialVersionUID:
  
  6693468726881121924L
- Class org.apache.flink.runtime.util.SerializableHashSet extends HashSet<T extends org.apache.flink.core.io.IOReadableWritable> implements Serializable
  
  serialVersionUID:
  
  -4615823301768215807L
- Class org.apache.flink.runtime.util.SerializableObject extends Object implements Serializable
  
  serialVersionUID:
  
  -7322636177391854669L
- Class org.apache.flink.runtime.util.SerializedValue extends Object implements Serializable
  
  serialVersionUID:
  
  -3564011643393683761L
  - Serialized Fields
    - serializedData
```
byte[] serializedData
```
      The serialized data
Package org.apache.flink.runtime.yarn
- Class org.apache.flink.runtime.yarn.FlinkYarnClusterStatus extends Object implements Serializable
  - Serialized Fields
    - numberOfTaskManagers
```
int numberOfTaskManagers
```
    - numberOfSlots
```
int numberOfSlots
```

Serialized Form

Package org.apache.flink.runtime

Class org.apache.flink.runtime.JobException extends Exception implements Serializable

Package org.apache.flink.runtime.accumulators

Class org.apache.flink.runtime.accumulators.AccumulatorEvent extends SerializedValue<Map<String,org.apache.flink.api.common.accumulators.Accumulator<?,?>>> implements Serializable

Serialized Fields

jobID

Class org.apache.flink.runtime.accumulators.StringifiedAccumulatorResult extends Object implements Serializable

Serialized Fields

name

type

value

Package org.apache.flink.runtime.blob

Class org.apache.flink.runtime.blob.BlobKey extends Object implements Serializable

Serialized Fields

key

Package org.apache.flink.runtime.broadcast

Class org.apache.flink.runtime.broadcast.InitializationTypeConflictException extends Exception implements Serializable

Serialized Fields

type

Class org.apache.flink.runtime.broadcast.MaterializationExpiredException extends Exception implements Serializable

Package org.apache.flink.runtime.client

Class org.apache.flink.runtime.client.JobCancellationException extends JobExecutionException implements Serializable

Class org.apache.flink.runtime.client.JobExecutionException extends Exception implements Serializable

Serialized Fields

jobID

Class org.apache.flink.runtime.client.JobStatusMessage extends Object implements Serializable

Serialized Fields

jobId

jobName

jobState

startTime

Class org.apache.flink.runtime.client.JobSubmissionException extends JobExecutionException implements Serializable

Class org.apache.flink.runtime.client.JobTimeoutException extends JobExecutionException implements Serializable

Class org.apache.flink.runtime.client.SerializedJobExecutionResult extends Object implements Serializable

Serialized Fields

jobId

accumulatorResults

netRuntime

Package org.apache.flink.runtime.deployment

Class org.apache.flink.runtime.deployment.InputChannelDeploymentDescriptor extends Object implements Serializable

Serialized Fields

consumedPartitionId

consumedPartitionLocation

Class org.apache.flink.runtime.deployment.InputGateDeploymentDescriptor extends Object implements Serializable

Serialized Fields

consumedResultId

consumedSubpartitionIndex

inputChannels

Class org.apache.flink.runtime.deployment.ResultPartitionDeploymentDescriptor extends Object implements Serializable

Serialized Fields

resultId

partitionId

partitionType

numberOfSubpartitions

Class org.apache.flink.runtime.deployment.ResultPartitionLocation extends Object implements Serializable

Serialized Fields

locationType

connectionId

Class org.apache.flink.runtime.deployment.TaskDeploymentDescriptor extends Object implements Serializable

Serialized Fields

jobID

vertexID

executionId

taskName

indexInSubtaskGroup

numberOfSubtasks

jobConfiguration

taskConfiguration

invokableClassName

producedPartitions

inputGates

targetSlotNumber

requiredJarFiles

operatorState

Package org.apache.flink.runtime.event.job

Class org.apache.flink.runtime.event.job.AbstractEvent extends Object implements Serializable

Serialized Fields

timestamp

sequenceNumber