Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/4666#discussion_r139635706
--- Diff: docs/dev/datastream_api.md ---
@@ -497,7 +497,9 @@ env.generateSequence(1,10).map(new
MyMapper()).setBufferTimeout(timeoutMillis);
LocalStreamEnvironment env =
StreamExecutionEnvironment.createLocalEnvironment
env.setBufferTimeout(timeoutMillis)
-env.genereateSequence(1,10).map(myMap).setBufferTimeout(timeoutMillis)
+def myMap : Long => Long = _ + 1 // `generateSequence` returns a
`DataStream[Long]` type
--- End diff --
This change makes the java/scala documentation inconsistent. The fact that
generateSequence returns longs is also irrelevant to this section as it is
about setting the buffer timeout.
---
