From 57172c09e21263d550775b8e50081981fa806f32 Mon Sep 17 00:00:00 2001
From: Akira Ajisaka <aajisaka@apache.org>
Date: Fri, 30 Jan 2015 01:10:02 +0900
Subject: [PATCH] MAPREDUCE-6231. Grep example job is not working on a
 fully-distributed cluster. (aajisaka)

(cherry picked from commit fe2188a0420f501ccfcba92e91d4b564ba86103e)
---
 hadoop-mapreduce-project/CHANGES.txt                           | 3 +++
 .../src/main/java/org/apache/hadoop/examples/Grep.java         | 2 ++
 2 files changed, 5 insertions(+)

diff --git a/hadoop-mapreduce-project/CHANGES.txt b/hadoop-mapreduce-project/CHANGES.txt
index 0eced620ee9..d7ee8fba17b 100644
--- a/hadoop-mapreduce-project/CHANGES.txt
+++ b/hadoop-mapreduce-project/CHANGES.txt
@@ -85,6 +85,9 @@ Release 2.7.0 - UNRELEASED
     MAPREDUCE-6230. Fixed RMContainerAllocator to update the new AMRMToken
     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
 
   INCOMPATIBLE CHANGES
diff --git a/hadoop-mapreduce-project/hadoop-mapreduce-examples/src/main/java/org/apache/hadoop/examples/Grep.java b/hadoop-mapreduce-project/hadoop-mapreduce-examples/src/main/java/org/apache/hadoop/examples/Grep.java
index 421afcd7ace..810d0dd1ad0 100644
--- a/hadoop-mapreduce-project/hadoop-mapreduce-examples/src/main/java/org/apache/hadoop/examples/Grep.java
+++ b/hadoop-mapreduce-project/hadoop-mapreduce-examples/src/main/java/org/apache/hadoop/examples/Grep.java
@@ -61,6 +61,7 @@ public class Grep extends Configured implements Tool {
     try {
       
       grepJob.setJobName("grep-search");
+      grepJob.setJarByClass(Grep.class);
 
       FileInputFormat.setInputPaths(grepJob, args[0]);
 
@@ -78,6 +79,7 @@ public class Grep extends Configured implements Tool {
 
       Job sortJob = new Job(conf);
       sortJob.setJobName("grep-sort");
+      sortJob.setJarByClass(Grep.class);
 
       FileInputFormat.setInputPaths(sortJob, tempDir);
       sortJob.setInputFormatClass(SequenceFileInputFormat.class);