flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Riccardo Diomedi (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-3630) Little mistake in documentation
Date Thu, 17 Mar 2016 09:46:33 GMT
Riccardo Diomedi created FLINK-3630:

             Summary: 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
            Priority: Minor

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
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;
out.collect(new Tuple2(word, count)); 

This message was sent by Atlassian JIRA

View raw message