Package org.apache.flink.kubernetes.operator.utils

Class FlinkResourceExceptionUtils

java.lang.Object

org.apache.flink.kubernetes.operator.utils.FlinkResourceExceptionUtils

public final class FlinkResourceExceptionUtils
extends java.lang.Object

Flink Resource Exception utilities.

Field Summary

Fields

Modifier and Type	Field	Description
static java.lang.String	LABELS

Constructor Summary

Constructors

Constructor	Description
FlinkResourceExceptionUtils()

Method Summary

Modifier and Type	Method	Description
static java.util.Optional<java.lang.String>	getSubstringWithMaxLength(java.lang.String str, int limit)
static <R extends AbstractFlinkResource> void	updateFlinkResourceException(java.lang.Throwable throwable, R resource, FlinkOperatorConfiguration conf)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

LABELS

public static final java.lang.String LABELS

See Also:

Constant Field Values

Constructor Detail

FlinkResourceExceptionUtils

public FlinkResourceExceptionUtils()

Method Detail

updateFlinkResourceException

public static <R extends AbstractFlinkResource> void updateFlinkResourceException(java.lang.Throwable throwable,
                                                                                  R resource,
                                                                                  FlinkOperatorConfiguration conf)

getSubstringWithMaxLength

public static java.util.Optional<java.lang.String> getSubstringWithMaxLength(java.lang.String str,
                                                                             int limit)