From b451dd7aaa28be7f76353159a2bfe256224737e9 Mon Sep 17 00:00:00 2001
From: Arun Murthy <acmurthy@apache.org>
Date: Tue, 1 Nov 2011 01:04:15 +0000
Subject: [PATCH] MAPREDUCE-3220. Fixed TestCombineOutputCollector. Contributed
 by Devaraj K.

git-svn-id: https://svn.apache.org/repos/asf/hadoop/common/trunk@1195745 13f79535-47bb-0310-9956-ffa450edef68
---
 hadoop-mapreduce-project/CHANGES.txt            |  2 ++
 .../mapred/TestCombineOutputCollector.java      | 17 +++++++----------
 2 files changed, 9 insertions(+), 10 deletions(-)

diff --git a/hadoop-mapreduce-project/CHANGES.txt b/hadoop-mapreduce-project/CHANGES.txt
index 4398d1cfd5c..d0301d7e25c 100644
--- a/hadoop-mapreduce-project/CHANGES.txt
+++ b/hadoop-mapreduce-project/CHANGES.txt
@@ -1892,6 +1892,8 @@ Release 0.23.0 - Unreleased
     MAPREDUCE-3321. Disabled a few MR tests for 0.23. (Hitesh Shah via
     acmurthy) 
 
+    MAPREDUCE-3220. Fixed TestCombineOutputCollector. (Devaraj K via acmurthy) 
+
 Release 0.22.0 - Unreleased
 
   INCOMPATIBLE CHANGES
diff --git a/hadoop-mapreduce-project/src/test/mapred/org/apache/hadoop/mapred/TestCombineOutputCollector.java b/hadoop-mapreduce-project/src/test/mapred/org/apache/hadoop/mapred/TestCombineOutputCollector.java
index 93560c157b1..0ffac847a4b 100644
--- a/hadoop-mapreduce-project/src/test/mapred/org/apache/hadoop/mapred/TestCombineOutputCollector.java
+++ b/hadoop-mapreduce-project/src/test/mapred/org/apache/hadoop/mapred/TestCombineOutputCollector.java
@@ -31,17 +31,17 @@
 import org.apache.hadoop.mapred.IFile.Writer;
 import org.apache.hadoop.mapred.Task.CombineOutputCollector;
 import org.apache.hadoop.mapred.Task.TaskReporter;
+import org.apache.hadoop.mapreduce.MRJobConfig;
 import org.junit.Test;
 
 public class TestCombineOutputCollector {
   private CombineOutputCollector<String, Integer> coc;
 
   Counters.Counter outCounter = new Counters.Counter() {
-    
+    private long value;
     @Override
     public void setValue(long value) {
-      // TODO Auto-generated method stub
-      
+      this.value = value;
     }
     
     @Override
@@ -52,14 +52,12 @@ public void setDisplayName(String displayName) {
     
     @Override
     public void increment(long incr) {
-      // TODO Auto-generated method stub
-      
+      this.value += incr;
     }
     
     @Override
     public long getValue() {
-      // TODO Auto-generated method stub
-      return 0;
+      return value;
     }
     
     @Override
@@ -82,8 +80,7 @@ public String makeEscapedCompactString() {
     
     @Override
     public long getCounter() {
-      // TODO Auto-generated method stub
-      return 0;
+      return value;
     }
     
     @Override
@@ -108,7 +105,7 @@ public void testCustomCollect() throws Throwable {
     Writer<String, Integer> mockWriter = mock(Writer.class);
 
     Configuration conf = new Configuration();
-    conf.set("mapred.combine.recordsBeforeProgress", "2");
+    conf.set(MRJobConfig.COMBINE_RECORDS_BEFORE_PROGRESS, "2");
     
     coc = new CombineOutputCollector<String, Integer>(outCounter, mockTaskReporter, conf);
     coc.setWriter(mockWriter);