You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2018/01/29 11:08:07 UTC
flink git commit: [hotfix][docs] Fix Scala code example in
Controlling Latency section
Repository: flink
Updated Branches:
refs/heads/master 71dee4e6f -> d2211ed53
[hotfix][docs] Fix Scala code example in Controlling Latency section
This closes #5299.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d2211ed5
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d2211ed5
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/d2211ed5
Branch: refs/heads/master
Commit: d2211ed53820e859e893beab2a92a4afe60b74fb
Parents: 71dee4e
Author: Alejandro Alcalde <al...@gmail.com>
Authored: Mon Jan 15 19:27:55 2018 +0100
Committer: zentol <ch...@apache.org>
Committed: Mon Jan 29 12:07:43 2018 +0100
----------------------------------------------------------------------
docs/dev/datastream_api.md | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/d2211ed5/docs/dev/datastream_api.md
----------------------------------------------------------------------
diff --git a/docs/dev/datastream_api.md b/docs/dev/datastream_api.md
index dee2f78..3cce5be 100644
--- a/docs/dev/datastream_api.md
+++ b/docs/dev/datastream_api.md
@@ -487,7 +487,7 @@ env.generateSequence(1,10).map(new MyMapper()).setBufferTimeout(timeoutMillis);
</div>
<div data-lang="scala" markdown="1">
{% highlight scala %}
-LocalStreamEnvironment env = StreamExecutionEnvironment.createLocalEnvironment
+val env: LocalStreamEnvironment = StreamExecutionEnvironment.createLocalEnvironment
env.setBufferTimeout(timeoutMillis)
env.generateSequence(1,10).map(myMap).setBufferTimeout(timeoutMillis)