flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Chesnay Schepler (JIRA)" <j...@apache.org>
Subject [jira] [Closed] (FLINK-3630) Little mistake in documentation
Date Fri, 15 Jul 2016 09:57:20 GMT

     [ https://issues.apache.org/jira/browse/FLINK-3630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]

Chesnay Schepler closed FLINK-3630.
-----------------------------------
       Resolution: Fixed
    Fix Version/s: 1.1.0

Fixed in 9a2057310eb22bae2601f2635b201e3a168a0feb

> Little mistake in documentation
> -------------------------------
>
>                 Key: FLINK-3630
>                 URL: https://issues.apache.org/jira/browse/FLINK-3630
>             Project: Flink
>          Issue Type: Bug
>          Components: DataSet API, Documentation
>    Affects Versions: 1.0.0
>            Reporter: Riccardo Diomedi
>            Assignee: Greg Hogan
>            Priority: Minor
>              Labels: documentation
>             Fix For: 1.1.0
>
>
> in section "GroupCombine on a Grouped DataSet" of the following link: https://ci.apache.org/projects/flink/flink-docs-release-1.0/apis/batch/dataset_transformations.html#groupreduce-on-grouped-dataset
> there is a little mistake in java code in both combine and reduce method(it's the same
mistake). The variable "word" is defined in the scope of the for loop so it cannot be used
in collect method.
> Possible solution could be to initialise the variable before the for and assign a value
inside the for.
> Something like:
> int count = 0;
> String word;
> for (String record : words) {
>     word = record;
>     count++;
> }
> out.collect(new Tuple2(word, count)); 



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Mime
View raw message