You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by fh...@apache.org on 2016/12/06 12:42:50 UTC
[2/4] flink git commit: [FLINK-5259] [docs] Fix wrong execution
environment in batch retry delays example.
[FLINK-5259] [docs] Fix wrong execution environment in batch retry delays example.
This closes #2943.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ebe228db
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/ebe228db
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/ebe228db
Branch: refs/heads/master
Commit: ebe228db74ede9bccc9b3c482b98acbb397a9130
Parents: 96239b3
Author: David Anderson <da...@alpinegizmo.com>
Authored: Mon Dec 5 11:39:46 2016 +0100
Committer: Fabian Hueske <fh...@apache.org>
Committed: Tue Dec 6 10:53:39 2016 +0100
----------------------------------------------------------------------
docs/dev/batch/fault_tolerance.md | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/ebe228db/docs/dev/batch/fault_tolerance.md
----------------------------------------------------------------------
diff --git a/docs/dev/batch/fault_tolerance.md b/docs/dev/batch/fault_tolerance.md
index ab870d0..f403791 100644
--- a/docs/dev/batch/fault_tolerance.md
+++ b/docs/dev/batch/fault_tolerance.md
@@ -77,13 +77,13 @@ You can set the retry delay for each program as follows (the sample shows the Da
<div class="codetabs" markdown="1">
<div data-lang="java" markdown="1">
{% highlight java %}
-StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
+ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();
env.getConfig().setExecutionRetryDelay(5000); // 5000 milliseconds delay
{% endhighlight %}
</div>
<div data-lang="scala" markdown="1">
{% highlight scala %}
-val env = StreamExecutionEnvironment.getExecutionEnvironment()
+val env = ExecutionEnvironment.getExecutionEnvironment()
env.getConfig.setExecutionRetryDelay(5000) // 5000 milliseconds delay
{% endhighlight %}
</div>