[FLINK-3630] Little mistake in documentation

• Type: Bug
• Status: Closed
• Priority: Minor
• Resolution: Fixed
• Affects Version/s: 1.0.0
• Fix Version/s: 1.1.0
• Component/s: API / DataSet, Documentation
• Labels: documentation
• Assignee: Greg Hogan
• Reporter: Riccardo Diomedi
• Created: 17/Mar/16 09:46
• Updated: 15/Jul/16 09:56
• Resolved: 15/Jul/16 09:56

Description

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));

Issue Links

• links to: GitHub Pull Request #2254