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:46:07 UTC
[2/2] 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/7bb6b696
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/7bb6b696
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/7bb6b696
Branch: refs/heads/release-1.1
Commit: 7bb6b696cfc0ff90416ea371f263abd03143e8f3
Parents: c567b0c
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 13:45:14 2016 +0100
----------------------------------------------------------------------
docs/apis/batch/fault_tolerance.md | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/7bb6b696/docs/apis/batch/fault_tolerance.md
----------------------------------------------------------------------
diff --git a/docs/apis/batch/fault_tolerance.md b/docs/apis/batch/fault_tolerance.md
index 51a6b41..6132b639a 100644
--- a/docs/apis/batch/fault_tolerance.md
+++ b/docs/apis/batch/fault_tolerance.md
@@ -79,13 +79,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>