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. |