You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by se...@apache.org on 2017/05/06 21:29:18 UTC
[4/4] flink git commit: [hotfix] [runtime] Correct some JavaDocs for
RestartIndividualStrategy
[hotfix] [runtime] Correct some JavaDocs for RestartIndividualStrategy
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e515b9bb
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/e515b9bb
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/e515b9bb
Branch: refs/heads/master
Commit: e515b9bb2e2c0b5aa9911dd0c91fb2016da3432f
Parents: dcfd37c
Author: shuai.xus <sh...@alibaba-inc.com>
Authored: Tue Apr 25 15:42:48 2017 +0800
Committer: Stephan Ewen <se...@apache.org>
Committed: Sat May 6 21:40:05 2017 +0200
----------------------------------------------------------------------
.../executiongraph/failover/RestartIndividualStrategy.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/e515b9bb/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/RestartIndividualStrategy.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/RestartIndividualStrategy.java b/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/RestartIndividualStrategy.java
index 0a449b8..0e7bca5 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/RestartIndividualStrategy.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/RestartIndividualStrategy.java
@@ -60,7 +60,7 @@ public class RestartIndividualStrategy extends FailoverStrategy {
private final SimpleCounter numTaskFailures;
/**
- * Creates a new failover strategy that recovers from failures by restarting all tasks
+ * Creates a new failover strategy that recovers from failures by restarting only the failed task
* of the execution graph.
*
* <p>The strategy will use the ExecutionGraph's future executor for callbacks.
@@ -72,7 +72,7 @@ public class RestartIndividualStrategy extends FailoverStrategy {
}
/**
- * Creates a new failover strategy that recovers from failures by restarting all tasks
+ * Creates a new failover strategy that recovers from failures by restarting only the failed task
* of the execution graph.
*
* @param executionGraph The execution graph to handle.