Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-10359

Scala example in DataSet docs is broken

Attach filesAttach ScreenshotVotersWatch issueWatchersCreate sub-taskLinkCloneUpdate Comment AuthorReplace String in CommentUpdate Comment VisibilityDelete Comments
    XMLWordPrintableJSON

Details

    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

        Activity

          This comment will be Viewable by All Users Viewable by All Users
          Cancel

          People

            yanghua vinoyang
            fhueske Fabian Hueske
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved:

              Slack

                Issue deployment