[FLINK-1669] [streaming] Test for streaming recovery from process fai…

…lure This closes #496
apache · Mar 29, 2015 · 56afefc · 56afefc
1 parent d03dd63
commit 56afefc
Show file tree

Hide file tree

Showing 4 changed files with 701 additions and 385 deletions.
diff --git a/.../src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java b/.../src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java
@@ -158,6 +158,17 @@ public StreamExecutionEnvironment setParallelism(int parallelism) {
 		return this;
 	}
 
+	/**
+	 * Sets the number of times that failed tasks are re-executed. A value of zero
+	 * effectively disables fault tolerance. A value of {@code -1} indicates that the system
+	 * default value (as defined in the configuration) should be used.
+	 *
+	 * @param numberOfExecutionRetries The number of times the system will try to re-execute failed tasks.
+	 */
+	public void setNumberOfExecutionRetries(int numberOfExecutionRetries) {
+		config.setNumberOfExecutionRetries(numberOfExecutionRetries);
+	}
+
 	/**
 	 * Sets the maximum time frequency (milliseconds) for the flushing of the
 	 * output buffers. By default the output buffers flush frequently to provide