Details
-
Improvement
-
Status: Resolved
-
Major
-
Resolution: Fixed
-
1.5.3, 1.6.0, 1.7.0
Description
The Scala example of https://ci.apache.org/projects/flink/flink-docs-release-1.6/dev/batch/dataset_transformations.html#combinable-groupreducefunctions is broken.
The asScala and the reduce call fetch the Java Iterator which may only fetched once.
The Iterable can be iterated over only once. Only the first call to 'iterator()' will succeed.
While we are on it, it would make sense to check the other examples as well.
Attachments
Issue Links
- links to