MAPREDUCE-6231. Grep example job is not working on a fully-distributed cluster. (aajisaka)
(cherry picked from commit fe2188a042
)
This commit is contained in:
parent
71c60af84e
commit
57172c09e2
|
@ -85,6 +85,9 @@ Release 2.7.0 - UNRELEASED
|
||||||
MAPREDUCE-6230. Fixed RMContainerAllocator to update the new AMRMToken
|
MAPREDUCE-6230. Fixed RMContainerAllocator to update the new AMRMToken
|
||||||
service name properly. (Jason Lowe via jianhe)
|
service name properly. (Jason Lowe via jianhe)
|
||||||
|
|
||||||
|
MAPREDUCE-6231. Grep example job is not working on a fully-distributed
|
||||||
|
cluster. (aajisaka)
|
||||||
|
|
||||||
Release 2.6.0 - 2014-11-18
|
Release 2.6.0 - 2014-11-18
|
||||||
|
|
||||||
INCOMPATIBLE CHANGES
|
INCOMPATIBLE CHANGES
|
||||||
|
|
|
@ -61,6 +61,7 @@ public class Grep extends Configured implements Tool {
|
||||||
try {
|
try {
|
||||||
|
|
||||||
grepJob.setJobName("grep-search");
|
grepJob.setJobName("grep-search");
|
||||||
|
grepJob.setJarByClass(Grep.class);
|
||||||
|
|
||||||
FileInputFormat.setInputPaths(grepJob, args[0]);
|
FileInputFormat.setInputPaths(grepJob, args[0]);
|
||||||
|
|
||||||
|
@ -78,6 +79,7 @@ public class Grep extends Configured implements Tool {
|
||||||
|
|
||||||
Job sortJob = new Job(conf);
|
Job sortJob = new Job(conf);
|
||||||
sortJob.setJobName("grep-sort");
|
sortJob.setJobName("grep-sort");
|
||||||
|
sortJob.setJarByClass(Grep.class);
|
||||||
|
|
||||||
FileInputFormat.setInputPaths(sortJob, tempDir);
|
FileInputFormat.setInputPaths(sortJob, tempDir);
|
||||||
sortJob.setInputFormatClass(SequenceFileInputFormat.class);
|
sortJob.setInputFormatClass(SequenceFileInputFormat.class);
|
||||||
|
|
Loading…
Reference in New Issue