org.apache.flink.kubernetes.kubeclient.decorators

Class FlinkConfMountDecorator

java.lang.Object

org.apache.flink.kubernetes.kubeclient.decorators.AbstractKubernetesStepDecorator

org.apache.flink.kubernetes.kubeclient.decorators.FlinkConfMountDecorator

All Implemented Interfaces:

KubernetesStepDecorator

public class FlinkConfMountDecorator
extends AbstractKubernetesStepDecorator

Mounts the log4j.properties, logback.xml, and flink-conf.yaml configuration on the JobManager or TaskManager pod.

Field Summary

Fields inherited from class org.apache.flink.kubernetes.kubeclient.decorators.AbstractKubernetesStepDecorator

logger

Constructor Summary

Constructors

Constructor and Description
FlinkConfMountDecorator(AbstractKubernetesParameters kubernetesComponentConf)

Method Summary

Modifier and Type	Method and Description
List<io.fabric8.kubernetes.api.model.HasMetadata>	buildAccompanyingKubernetesResources() Note that the method could have a side effect of modifying the Flink Configuration object, such as update the JobManager address.
FlinkPod	decorateFlinkPod(FlinkPod flinkPod) Apply transformations on the given FlinkPod in accordance to this feature.
static String	getFlinkConfConfigMapName(String clusterId)

Methods inherited from class java.lang.Object

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

Constructor Detail

FlinkConfMountDecorator

public FlinkConfMountDecorator(AbstractKubernetesParameters kubernetesComponentConf)

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

buildAccompanyingKubernetesResources

public List<io.fabric8.kubernetes.api.model.HasMetadata> buildAccompanyingKubernetesResources()
                                                                                       throws IOException

Description copied from class: AbstractKubernetesStepDecorator

Note that the method could have a side effect of modifying the Flink Configuration object, such as update the JobManager address.

Specified by:

buildAccompanyingKubernetesResources in interface KubernetesStepDecorator

Overrides:

buildAccompanyingKubernetesResources in class AbstractKubernetesStepDecorator

Throws:

IOException

getFlinkConfConfigMapName

@VisibleForTesting
public static String getFlinkConfConfigMapName(String clusterId)