Class FlinkOperatorConfiguration.FlinkOperatorRetryConfiguration
- java.lang.Object
-
- org.apache.flink.kubernetes.operator.config.FlinkOperatorConfiguration.FlinkOperatorRetryConfiguration
-
- All Implemented Interfaces:
io.javaoperatorsdk.operator.api.config.RetryConfiguration
- Enclosing class:
- FlinkOperatorConfiguration
protected static class FlinkOperatorConfiguration.FlinkOperatorRetryConfiguration extends java.lang.Object implements io.javaoperatorsdk.operator.api.config.RetryConfiguration
Enables configurable retry mechanism for reconciliation errors.
-
-
Constructor Summary
Constructors Constructor Description FlinkOperatorRetryConfiguration(org.apache.flink.configuration.Configuration operatorConfig)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description long
getInitialInterval()
double
getIntervalMultiplier()
int
getMaxAttempts()
long
getMaxInterval()
-
-
-
Method Detail
-
getMaxAttempts
public int getMaxAttempts()
- Specified by:
getMaxAttempts
in interfaceio.javaoperatorsdk.operator.api.config.RetryConfiguration
-
getInitialInterval
public long getInitialInterval()
- Specified by:
getInitialInterval
in interfaceio.javaoperatorsdk.operator.api.config.RetryConfiguration
-
getIntervalMultiplier
public double getIntervalMultiplier()
- Specified by:
getIntervalMultiplier
in interfaceio.javaoperatorsdk.operator.api.config.RetryConfiguration
-
getMaxInterval
public long getMaxInterval()
- Specified by:
getMaxInterval
in interfaceio.javaoperatorsdk.operator.api.config.RetryConfiguration
-
-