Key Default Description
kubernetes.cluster-id
(none) The custom name for the Flink cluster on Kubernetes. It could be specified by -nm argument. If it's not set, the client will generate a random UUID name
kubernetes.connection.retry.interval.ms
1000 The retry interval in milliseconds for RM talking to kubernetes.
kubernetes.connection.retry.times
120 The max retry attempts for RM talking to kubernetes.
kubernetes.container-start-command-template
"%java% %classpath% %jvmmem% %jvmopts% %logging% %class%" Template for the kubernetes container start invocation
kubernetes.container.files
(none) Files to be used for Flink containers, will be transferred to flink conf directory and appended to classpath in containers.
kubernetes.container.image
"flink-k8s:latest" Container image to use for Flink containers. Individual container types (e.g. jobmanager or taskmanager) can also be configured to use different images if desired, by setting the container type-specific image name.
kubernetes.container.image.pullPolicy
"IfNotPresent" Kubernetes image pull policy. Valid values are Always, Never, and IfNotPresent.
kubernetes.destroy-perjob-cluster.after-job-finished
true Whether to kill perjob-cluster on kubernetes after job finished.If you want to check logs and view dashboard after job finished, set this to false.
kubernetes.flink.conf.dir
"/etc/flink/conf" The conf dir will be mounted in pod.
kubernetes.jobmanager.container.image
(none) Container image to use for the jobmanager.
kubernetes.jobmanager.container.name
"flink-kubernetes-jobmanager" Name of the jobmanager container.
kubernetes.jobmanager.cpu
1.0 The number of cpu used by job manager
kubernetes.jobmanager.pod.name
"jobmanager" Name of the jobmanager pod.
kubernetes.jobmanager.service-account
"default" Service account that is used by jobmanager within kubernetes cluster. The job manager uses this service account when requesting taskmanager pods from the API server.
kubernetes.master.url
"localhost:8080" The kubernetes master url.
kubernetes.namespace
"default" The namespace that will be used for running the jobmanager and taskmanager pods.
kubernetes.program.args
(none) Arguments specified for user program.
kubernetes.program.entrypoint.class
(none) Class with the program entry point ("main" method or "getPlan()" method. Only needed if the JAR file does not specify the class in its manifest.
kubernetes.service.exposed.type
"CLUSTER_IP" It could be CLUSTER_IP(default)/NODE_PORT/LOAD_BALANCER/EXTERNAL_NAME.
kubernetes.service.external.address
"localhost" The exposed address of kubernetes service to submit job and view dashboard.
kubernetes.taskmanager.count
1 The task manager count for session cluster.
kubernetes.taskmanager.register-timeout
120 The register timeout for a task manager before released by resource manager. In seconds.In case of a task manager took very long time to be launched.
kubernetes.workernode.max-failed-attempts
100 The max failed attempts for work node.