You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2020/06/02 14:39:47 UTC
[flink] 01/02: [FLINK-17970] Rename cluster.io-executor.pool-size
config option into cluster.io-pool.size
This is an automated email from the ASF dual-hosted git repository.
trohrmann pushed a commit to branch release-1.11
in repository https://gitbox.apache.org/repos/asf/flink.git
commit b02b165cb9c56911899fabd65bbde69203ae6ad5
Author: Till Rohrmann <tr...@apache.org>
AuthorDate: Wed May 27 14:38:12 2020 +0200
[FLINK-17970] Rename cluster.io-executor.pool-size config option into cluster.io-pool.size
Shortens the cluster.io-pool.size config option and updates the description of it.
---
docs/_includes/generated/cluster_configuration.html | 4 ++--
docs/_includes/generated/expert_fault_tolerance_section.html | 4 ++--
.../main/java/org/apache/flink/configuration/ClusterOptions.java | 7 ++++---
3 files changed, 8 insertions(+), 7 deletions(-)
diff --git a/docs/_includes/generated/cluster_configuration.html b/docs/_includes/generated/cluster_configuration.html
index 460c1db..f6a66eb 100644
--- a/docs/_includes/generated/cluster_configuration.html
+++ b/docs/_includes/generated/cluster_configuration.html
@@ -15,10 +15,10 @@
<td>Enable the slot spread out allocation strategy. This strategy tries to spread out the slots evenly across all available <span markdown="span">`TaskExecutors`</span>.</td>
</tr>
<tr>
- <td><h5>cluster.io-executor.pool-size</h5></td>
+ <td><h5>cluster.io-pool.size</h5></td>
<td style="word-wrap: break-word;">(none)</td>
<td>Integer</td>
- <td>The pool size of io executor for cluster entry-point and mini cluster. It's undefined by default and will use the number of CPU cores (hardware contexts) that the cluster entry-point JVM has access to.</td>
+ <td>The size of the IO executor pool used by the cluster to execute blocking IO operations (Master as well as TaskManager processes). By default it will use the number of CPU cores (hardware contexts) that the cluster process has access to. Increasing the pool size allows to run more IO operations concurrently.</td>
</tr>
<tr>
<td><h5>cluster.registration.error-delay</h5></td>
diff --git a/docs/_includes/generated/expert_fault_tolerance_section.html b/docs/_includes/generated/expert_fault_tolerance_section.html
index 8e3d6fc..8799460 100644
--- a/docs/_includes/generated/expert_fault_tolerance_section.html
+++ b/docs/_includes/generated/expert_fault_tolerance_section.html
@@ -9,10 +9,10 @@
</thead>
<tbody>
<tr>
- <td><h5>cluster.io-executor.pool-size</h5></td>
+ <td><h5>cluster.io-pool.size</h5></td>
<td style="word-wrap: break-word;">(none)</td>
<td>Integer</td>
- <td>The pool size of io executor for cluster entry-point and mini cluster. It's undefined by default and will use the number of CPU cores (hardware contexts) that the cluster entry-point JVM has access to.</td>
+ <td>The size of the IO executor pool used by the cluster to execute blocking IO operations (Master as well as TaskManager processes). By default it will use the number of CPU cores (hardware contexts) that the cluster process has access to. Increasing the pool size allows to run more IO operations concurrently.</td>
</tr>
<tr>
<td><h5>cluster.registration.error-delay</h5></td>
diff --git a/flink-core/src/main/java/org/apache/flink/configuration/ClusterOptions.java b/flink-core/src/main/java/org/apache/flink/configuration/ClusterOptions.java
index e483b73..b3841aa 100644
--- a/flink-core/src/main/java/org/apache/flink/configuration/ClusterOptions.java
+++ b/flink-core/src/main/java/org/apache/flink/configuration/ClusterOptions.java
@@ -65,11 +65,12 @@ public class ClusterOptions {
@Documentation.Section(Documentation.Sections.EXPERT_FAULT_TOLERANCE)
public static final ConfigOption<Integer> CLUSTER_IO_EXECUTOR_POOL_SIZE = ConfigOptions
- .key("cluster.io-executor.pool-size")
+ .key("cluster.io-pool.size")
.intType()
.noDefaultValue()
- .withDescription("The pool size of io executor for cluster entry-point and mini cluster. " +
- "It's undefined by default and will use the number of CPU cores (hardware contexts) that the cluster entry-point JVM has access to.");
+ .withDescription("The size of the IO executor pool used by the cluster to execute blocking IO operations (Master as well as TaskManager processes). " +
+ "By default it will use the number of CPU cores (hardware contexts) that the cluster process has access to. " +
+ "Increasing the pool size allows to run more IO operations concurrently.");
@Documentation.Section(Documentation.Sections.EXPERT_SCHEDULING)
public static final ConfigOption<Boolean> EVENLY_SPREAD_OUT_SLOTS_STRATEGY = ConfigOptions