flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From se...@apache.org
Subject [4/4] flink git commit: [hotfix] [runtime] Correct some JavaDocs for RestartIndividualStrategy
Date Sat, 06 May 2017 21:29:18 GMT
[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 <shuai.xus@alibaba-inc.com>
Authored: Tue Apr 25 15:42:48 2017 +0800
Committer: Stephan Ewen <sewen@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.


Mime
View raw message