Package org.apache.flink.kubernetes.kubeclient.decorators

Class HadoopConfMountDecorator

  • All Implemented Interfaces:
    KubernetesStepDecorator
    public class HadoopConfMountDecorator
extends AbstractKubernetesStepDecorator
    Mount the custom Hadoop Configuration to the JobManager(s)/TaskManagers. We provide two options: 1. Mount an existing ConfigMap containing custom Hadoop Configuration. 2. Create and mount a dedicated ConfigMap containing the custom Hadoop configuration from a local directory specified via the HADOOP_CONF_DIR or HADOOP_HOME environment variable.

    • Method Detail

      • decorateFlinkPod

        public FlinkPod decorateFlinkPod​(FlinkPod flinkPod)
        Description copied from class: AbstractKubernetesStepDecorator
        Apply transformations on the given FlinkPod in accordance to this feature. Note that we should return a FlinkPod that keeps all of the properties of the passed FlinkPod object.

        So this is correct: 

        
 Pod decoratedPod = new PodBuilder(pod) // Keeps the original state
     ...
     .build()

 Container decoratedContainer = new ContainerBuilder(container) // Keeps the original state
     ...
     .build()

 FlinkPod decoratedFlinkPod = new FlinkPodBuilder(flinkPod) // Keeps the original state
     ...
     .build()

        And this is the incorrect: 

        
 Pod decoratedPod = new PodBuilder() // Loses the original state
     ...
     .build()

 Container decoratedContainer = new ContainerBuilder() // Loses the original state
     ...
     .build()

 FlinkPod decoratedFlinkPod = new FlinkPodBuilder() // Loses the original state
     ...
     .build()
        Specified by:
        decorateFlinkPod in interface KubernetesStepDecorator
        Overrides:
        decorateFlinkPod in class AbstractKubernetesStepDecorator

      • getHadoopConfConfigMapName

        public static String getHadoopConfConfigMapName​(String clusterId)