This is an automated email from the ASF dual-hosted git repository.

trohrmann pushed a commit to branch release-1.6
in repository https://gitbox.apache.org/repos/asf/flink.git

commit 869e22192a4868eca8f81e239dc4b4e502e0b989
Author: gyao <g...@data-artisans.com>
AuthorDate: Thu Aug 9 13:34:46 2018 +0200

    [hotfix][docs] Add missing space after end of sentence.
---
 docs/_includes/generated/job_manager_configuration.html       |  2 +-
 .../org/apache/flink/configuration/JobManagerOptions.java     | 11 ++++++++++-
 2 files changed, 11 insertions(+), 2 deletions(-)

diff --git a/docs/_includes/generated/job_manager_configuration.html 
b/docs/_includes/generated/job_manager_configuration.html
index 0353874..0458af2 100644
--- a/docs/_includes/generated/job_manager_configuration.html
+++ b/docs/_includes/generated/job_manager_configuration.html
@@ -20,7 +20,7 @@
         <tr>
             <td><h5>jobmanager.execution.failover-strategy</h5></td>
             <td style="word-wrap: break-word;">"full"</td>
-            <td>The maximum number of prior execution attempts kept in 
history.</td>
+            <td>This option specifies how the job computation recovers from 
task failures. Accepted values are:<ul><li>'full': Restarts all 
tasks.</li><li>'individual': Restarts only the failed task. Should only be used 
if all tasks are independent components.</li><li>'region': Restarts all tasks 
that could be affected by the task failure.</li></ul></td>
         </tr>
         <tr>
             <td><h5>jobmanager.heap.size</h5></td>
diff --git 
a/flink-core/src/main/java/org/apache/flink/configuration/JobManagerOptions.java
 
b/flink-core/src/main/java/org/apache/flink/configuration/JobManagerOptions.java
index 2bb5732..e845d60 100644
--- 
a/flink-core/src/main/java/org/apache/flink/configuration/JobManagerOptions.java
+++ 
b/flink-core/src/main/java/org/apache/flink/configuration/JobManagerOptions.java
@@ -20,8 +20,10 @@ package org.apache.flink.configuration;
 
 import org.apache.flink.annotation.PublicEvolving;
 import org.apache.flink.annotation.docs.Documentation;
+import org.apache.flink.configuration.description.Description;
 
 import static org.apache.flink.configuration.ConfigOptions.key;
+import static org.apache.flink.configuration.description.TextElement.text;
 
 /**
  * Configuration options for the JobManager.
@@ -107,7 +109,14 @@ public class JobManagerOptions {
        public static final ConfigOption<String> EXECUTION_FAILOVER_STRATEGY =
                key("jobmanager.execution.failover-strategy")
                        .defaultValue("full")
-                       .withDescription("The maximum number of prior execution 
attempts kept in history.");
+                       .withDescription(Description.builder()
+                               .text("This option specifies how the job 
computation recovers from task failures. " +
+                                       "Accepted values are:")
+                               .list(
+                                       text("'full': Restarts all tasks."),
+                                       text("'individual': Restarts only the 
failed task. Should only be used if all tasks are independent components."),
+                                       text("'region': Restarts all tasks that 
could be affected by the task failure.")
+                               ).build());
 
        /**
         * This option specifies the interval in order to trigger a resource 
manager reconnection if the connection

Reply via email to