flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From fhue...@apache.org
Subject [2/2] flink git commit: [FLINK-5259] [docs] Fix wrong execution environment in batch retry delays example.
Date Tue, 06 Dec 2016 12:46:07 GMT
[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 <david@alpinegizmo.com>
Authored: Mon Dec 5 11:39:46 2016 +0100
Committer: Fabian Hueske <fhueske@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>


Mime
View raw message