MAPREDUCE-3630. Fixes a NullPointer exception while running TeraGen - if a map is asked to generate 0 records. (Contributed by Mahadev Konar)
git-svn-id: https://svn.apache.org/repos/asf/hadoop/common/trunk@1235641 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
c43a5a992e
commit
a02f07c4bc
@ -555,6 +555,9 @@ Release 0.23.1 - Unreleased
|
|||||||
MAPREDUCE-3717. JobClient test jar has missing files to run all the test programs.
|
MAPREDUCE-3717. JobClient test jar has missing files to run all the test programs.
|
||||||
(mahadev)
|
(mahadev)
|
||||||
|
|
||||||
|
MAPREDUCE-3630. Fixes a NullPointer exception while running TeraGen - if a
|
||||||
|
map is asked to generate 0 records. (Mahadev Konar via sseth)
|
||||||
|
|
||||||
Release 0.23.0 - 2011-11-01
|
Release 0.23.0 - 2011-11-01
|
||||||
|
|
||||||
INCOMPATIBLE CHANGES
|
INCOMPATIBLE CHANGES
|
||||||
|
@ -238,9 +238,11 @@ public void map(LongWritable row, NullWritable ignored,
|
|||||||
|
|
||||||
@Override
|
@Override
|
||||||
public void cleanup(Context context) {
|
public void cleanup(Context context) {
|
||||||
|
if (checksumCounter != null) {
|
||||||
checksumCounter.increment(total.getLow8());
|
checksumCounter.increment(total.getLow8());
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
}
|
||||||
|
|
||||||
private static void usage() throws IOException {
|
private static void usage() throws IOException {
|
||||||
System.err.println("teragen <num rows> <output dir>");
|
System.err.println("teragen <num rows> <output dir>");
|
||||||
@ -307,5 +309,4 @@ public static void main(String[] args) throws Exception {
|
|||||||
int res = ToolRunner.run(new Configuration(), new TeraGen(), args);
|
int res = ToolRunner.run(new Configuration(), new TeraGen(), args);
|
||||||
System.exit(res);
|
System.exit(res);
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user