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

Class InitTaskManagerDecorator

    • 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