Uses of Class
org.apache.flink.util.FlinkRuntimeException

Packages that use FlinkRuntimeException

Package	Description
org.apache.flink.api.common.operators
org.apache.flink.runtime.checkpoint
org.apache.flink.runtime.rpc.pekko.exceptions
org.apache.flink.runtime.util
org.apache.flink.streaming.api.datastream
org.apache.flink.streaming.runtime.tasks	This package contains classes that realize streaming tasks.
org.apache.flink.table.functions.hive
org.apache.flink.table.runtime.operators.multipleinput.output
org.apache.flink.util

Uses of FlinkRuntimeException in org.apache.flink.api.common.operators

Methods in org.apache.flink.api.common.operators that throw FlinkRuntimeException

Modifier and Type	Method and Description
boolean	MailboxExecutor.tryYield() This method attempts to run the command at the head of the mailbox.
void	MailboxExecutor.yield() This method starts running the command at the head of the mailbox and is intended to be used by the mailbox thread to yield from a currently ongoing action to another command.

Uses of FlinkRuntimeException in org.apache.flink.runtime.checkpoint

Subclasses of FlinkRuntimeException in org.apache.flink.runtime.checkpoint

Modifier and Type	Class and Description
static class	FinishedTaskStateProvider.PartialFinishingNotSupportedByStateException Thrown when some subtasks of the operator have been finished but state doesn't support that (e.g.

Uses of FlinkRuntimeException in org.apache.flink.runtime.rpc.pekko.exceptions

Subclasses of FlinkRuntimeException in org.apache.flink.runtime.rpc.pekko.exceptions

Modifier and Type	Class and Description
class	RpcInvalidStateException Exception which indicates an invalid state.

Uses of FlinkRuntimeException in org.apache.flink.runtime.util

Methods in org.apache.flink.runtime.util that throw FlinkRuntimeException

Modifier and Type	Method and Description
static boolean	HadoopUtils.isMaxHadoopVersion(int major, int minor) Checks if the Hadoop dependency is at most the given version.
static boolean	HadoopUtils.isMinHadoopVersion(int major, int minor) Checks if the Hadoop dependency is at least the given version.

Uses of FlinkRuntimeException in org.apache.flink.streaming.api.datastream

Subclasses of FlinkRuntimeException in org.apache.flink.streaming.api.datastream

Modifier and Type	Class and Description
class	UnsupportedTimeCharacteristicException An exception that indicates that a time characteristic was used that is not supported in the current operation.

Uses of FlinkRuntimeException in org.apache.flink.streaming.runtime.tasks

Subclasses of FlinkRuntimeException in org.apache.flink.streaming.runtime.tasks

Modifier and Type	Class and Description
class	ExceptionInChainedOperatorException A special exception that signifies that the cause exception came from a chained operator.

Uses of FlinkRuntimeException in org.apache.flink.table.functions.hive

Subclasses of FlinkRuntimeException in org.apache.flink.table.functions.hive

Modifier and Type	Class and Description
class	FlinkHiveUDFException Hive UDF related exceptions in Flink.

Uses of FlinkRuntimeException in org.apache.flink.table.runtime.operators.multipleinput.output

Subclasses of FlinkRuntimeException in org.apache.flink.table.runtime.operators.multipleinput.output

Modifier and Type	Class and Description
class	ExceptionInMultipleInputOperatorException A special exception that signifies that the cause exception came from a MultipleInputStreamOperatorBase.

Uses of FlinkRuntimeException in org.apache.flink.util

Subclasses of FlinkRuntimeException in org.apache.flink.util

Modifier and Type	Class and Description
class	WrappingRuntimeException A runtime exception that is explicitly used to wrap non-runtime exceptions.

Methods in org.apache.flink.util that throw FlinkRuntimeException

Modifier and Type	Method and Description
T	OptionalFailure.getUnchecked()