class JavaCmdTaskManagerDecorator extends AbstractKubernetesStepDecorator {

	@Override
	public FlinkPod decorateFlinkPod(FlinkPod flinkPod) {
		final Container mainContainerWithStartCmd = new ContainerBuilder(flinkPod.getMainContainer())
			.withCommand(kubernetesTaskManagerParameters.getContainerEntrypoint())
			.withArgs(Arrays.asList(NATIVE_KUBERNETES_COMMAND, getTaskManagerStartCommand()))
			.build();

		return new FlinkPod.Builder(flinkPod)
			.withMainContainer(mainContainerWithStartCmd)
			.build();
	}

	public  JavaCmdTaskManagerDecorator(KubernetesTaskManagerParameters kubernetesTaskManagerParameters);

}