org.apache.flink.runtime.jobmanager

Class PartitionProducerDisposedException

java.lang.Object

java.lang.Throwable

java.lang.Exception

org.apache.flink.runtime.jobmanager.PartitionProducerDisposedException

All Implemented Interfaces:

Serializable

public class PartitionProducerDisposedException
extends Exception

Exception returned to a TaskManager on JobManagerMessages.RequestPartitionProducerState if the producer of a partition has been disposed.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
PartitionProducerDisposedException(ResultPartitionID resultPartitionID)

Method Summary

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

PartitionProducerDisposedException

public PartitionProducerDisposedException(ResultPartitionID resultPartitionID)