Class DefaultValidator
- java.lang.Object
-
- org.apache.flink.kubernetes.operator.validation.DefaultValidator
-
- All Implemented Interfaces:
org.apache.flink.core.plugin.Plugin
,FlinkResourceValidator
public class DefaultValidator extends java.lang.Object implements FlinkResourceValidator
Default validator implementation forFlinkDeployment
.
-
-
Constructor Summary
Constructors Constructor Description DefaultValidator(FlinkConfigManager configManager)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static java.util.Optional<java.lang.String>
validateAutoScalerFlinkConfiguration(java.util.Map<java.lang.String,java.lang.String> effectiveConfig)
java.util.Optional<java.lang.String>
validateDeployment(FlinkDeployment deployment)
Validate and return optional error.java.util.Optional<java.lang.String>
validateSessionJob(FlinkSessionJob sessionJob, java.util.Optional<FlinkDeployment> sessionOpt)
Validate and return optional error.
-
-
-
Constructor Detail
-
DefaultValidator
public DefaultValidator(FlinkConfigManager configManager)
-
-
Method Detail
-
validateDeployment
public java.util.Optional<java.lang.String> validateDeployment(FlinkDeployment deployment)
Description copied from interface:FlinkResourceValidator
Validate and return optional error.- Specified by:
validateDeployment
in interfaceFlinkResourceValidator
- Parameters:
deployment
- A Flink application or session cluster deployment.- Returns:
- Optional error string, should be present iff validation resulted in an error
-
validateSessionJob
public java.util.Optional<java.lang.String> validateSessionJob(FlinkSessionJob sessionJob, java.util.Optional<FlinkDeployment> sessionOpt)
Description copied from interface:FlinkResourceValidator
Validate and return optional error.- Specified by:
validateSessionJob
in interfaceFlinkResourceValidator
- Parameters:
sessionJob
- the session job to be validated.sessionOpt
- the target session cluster of the session job to be validated.- Returns:
- Optional error string, should be present iff validation resulted in an error
-
validateAutoScalerFlinkConfiguration
public static java.util.Optional<java.lang.String> validateAutoScalerFlinkConfiguration(java.util.Map<java.lang.String,java.lang.String> effectiveConfig)
-
-