[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 <[email protected]> Authored: Tue Apr 25 15:42:48 2017 +0800 Committer: Stephan Ewen <[email protected]> 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.
