[FLINK-22006][doc] Add documentation about how to configure Fabric8 K…

…ubernetes client This closes #15480.
apache · Apr 7, 2021 · 4ea9933 · 4ea9933
1 parent aef2392
commit 4ea9933
Show file tree

Hide file tree

Showing 2 changed files with 23 additions and 0 deletions.
diff --git a/docs/deployment/resource-providers/native_kubernetes.md b/docs/deployment/resource-providers/native_kubernetes.md
@@ -163,6 +163,17 @@ $ echo 'stop' | ./bin/kubernetes-session.sh \
 
 The Kubernetes-specific configuration options are listed on the [configuration page]({% link deployment/config.md %}#kubernetes).
 
+Flink uses [Fabric8 Kubernetes client](https://github.com/fabric8io/kubernetes-client) to communicate with Kubernetes APIServer to create/delete Kubernetes resources(e.g. Deployment, Pod, ConfigMap, Service, etc.), as well as watch the Pods and ConfigMaps.
+Except for the above Flink config options, some [expert options](https://github.com/fabric8io/kubernetes-client#configuring-the-client) of Fabric8 Kubernetes client could be configured via system properties or environment variables.
+
+For example, users could use the following Flink config options to set the concurrent max requests, which allows running more jobs in a session cluster when [Kubernetes HA Services]({% link deployment/ha/kubernetes_ha.md %}) are used.
+Please note that, each Flink job will consume `3` concurrent requests.
+
+```yaml
+containerized.master.env.KUBERNETES_MAX_CONCURRENT_REQUESTS: 200
+env.java.opts.jobmanager: "-Dkubernetes.max.concurrent.requests=200"
+```
+
 ### Accessing Flink's Web UI
 
 Flink's Web UI and REST endpoint can be exposed in several ways via the [kubernetes.rest-service.exposed.type]({% link deployment/config.md %}#kubernetes-rest-service-exposed-type) configuration option.

diff --git a/docs/deployment/resource-providers/native_kubernetes.zh.md b/docs/deployment/resource-providers/native_kubernetes.zh.md
@@ -163,6 +163,18 @@ $ echo 'stop' | ./bin/kubernetes-session.sh \
 
 The Kubernetes-specific configuration options are listed on the [configuration page]({% link deployment/config.zh.md %}#kubernetes).
 
+
+Flink uses [Fabric8 Kubernetes client](https://github.com/fabric8io/kubernetes-client) to communicate with Kubernetes APIServer to create/delete Kubernetes resources(e.g. Deployment, Pod, ConfigMap, Service, etc.), as well as watch the Pods and ConfigMaps.
+Except for the above Flink config options, some [expert options](https://github.com/fabric8io/kubernetes-client#configuring-the-client) of Fabric8 Kubernetes client could be configured via system properties or environment variables.
+
+For example, users could use the following Flink config options to set the concurrent max requests, which allows running more jobs in a session cluster when [Kubernetes HA Services]({% link deployment/ha/kubernetes_ha.zh.md %}) are used.
+Please note that, each Flink job will consume `3` concurrent requests.
+
+```yaml
+containerized.master.env.KUBERNETES_MAX_CONCURRENT_REQUESTS: 200
+env.java.opts.jobmanager: "-Dkubernetes.max.concurrent.requests=200"
+```
+
 ### Accessing Flink's Web UI
 
 Flink's Web UI and REST endpoint can be exposed in several ways via the [kubernetes.rest-service.exposed.type]({% link deployment/config.zh.md %}#kubernetes-rest-service-exposed-type) configuration option.