Author: tomwhite
Date: Fri Aug 31 07:46:17 2007
New Revision: 571483
URL: http://svn.apache.org/viewvc?rev=571483&view=rev
Log:
HADOOP-1810. Fix incorrect value type in MRBench (SmallJobs). Contributed by
Devaraj Das
Modified:
lucene/hadoop/trunk/CHANGES.txt
lucene/hadoop/trunk/src/test/org/apache/hadoop/mapred/MRBench.java
Modified: lucene/hadoop/trunk/CHANGES.txt
URL:
http://svn.apache.org/viewvc/lucene/hadoop/trunk/CHANGES.txt?rev=571483&r1=571482&r2=571483&view=diff
==============================================================================
--- lucene/hadoop/trunk/CHANGES.txt (original)
+++ lucene/hadoop/trunk/CHANGES.txt Fri Aug 31 07:46:17 2007
@@ -79,6 +79,9 @@
HADOOP-1795. Fix so that jobs can generate output file names with
special characters. (Frédéric Bertin via cutting)
+ HADOOP-1810. Fix incorrect value type in MRBench (SmallJobs)
+ (Devaraj Das via tomwhite)
+
IMPROVEMENTS
HADOOP-1779. Replace INodeDirectory.getINode() by a getExistingPathINodes()
Modified: lucene/hadoop/trunk/src/test/org/apache/hadoop/mapred/MRBench.java
URL:
http://svn.apache.org/viewvc/lucene/hadoop/trunk/src/test/org/apache/hadoop/mapred/MRBench.java?rev=571483&r1=571482&r2=571483&view=diff
==============================================================================
--- lucene/hadoop/trunk/src/test/org/apache/hadoop/mapred/MRBench.java
(original)
+++ lucene/hadoop/trunk/src/test/org/apache/hadoop/mapred/MRBench.java Fri Aug
31 07:46:17 2007
@@ -33,6 +33,7 @@
import org.apache.hadoop.io.UTF8;
import org.apache.hadoop.io.Writable;
import org.apache.hadoop.io.WritableComparable;
+import org.apache.hadoop.io.Text;
/**
* Runs a job multiple times and takes average of all runs.
@@ -52,9 +53,9 @@
* writes out data as text again.
*/
public static class Map extends MapReduceBase
- implements Mapper<WritableComparable, UTF8, UTF8, UTF8> {
+ implements Mapper<WritableComparable, Text, UTF8, UTF8> {
- public void map(WritableComparable key, UTF8 value,
+ public void map(WritableComparable key, Text value,
OutputCollector<UTF8, UTF8> output,
Reporter reporter) throws IOException
{
