Repository: incubator-carbondata
Updated Branches:
  refs/heads/master 065381995 -> d51387b81


FIxed testcase in hadoop 2.7.2


Project: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/repo
Commit: 
http://git-wip-us.apache.org/repos/asf/incubator-carbondata/commit/bb95dc64
Tree: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/tree/bb95dc64
Diff: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/diff/bb95dc64

Branch: refs/heads/master
Commit: bb95dc64344fe49169a4c2d6ec2011ea785b1580
Parents: 0653819
Author: ravipesala <ravi.pes...@gmail.com>
Authored: Mon Apr 10 18:55:52 2017 +0530
Committer: ravipesala <ravi.pes...@gmail.com>
Committed: Mon Apr 10 18:55:52 2017 +0530

----------------------------------------------------------------------
 .../org/apache/carbondata/hadoop/ft/CarbonInputMapperTest.java    | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-carbondata/blob/bb95dc64/hadoop/src/test/java/org/apache/carbondata/hadoop/ft/CarbonInputMapperTest.java
----------------------------------------------------------------------
diff --git 
a/hadoop/src/test/java/org/apache/carbondata/hadoop/ft/CarbonInputMapperTest.java
 
b/hadoop/src/test/java/org/apache/carbondata/hadoop/ft/CarbonInputMapperTest.java
index 0d751fc..6e6f2bd 100644
--- 
a/hadoop/src/test/java/org/apache/carbondata/hadoop/ft/CarbonInputMapperTest.java
+++ 
b/hadoop/src/test/java/org/apache/carbondata/hadoop/ft/CarbonInputMapperTest.java
@@ -135,7 +135,7 @@ public class CarbonInputMapperTest extends TestCase {
     return 0;
   }
 
-  public static class Map extends Mapper<Void, Object[], Void, Text> {
+  public static class Map extends Mapper<Void, Object[], Text, Text> {
 
     private BufferedWriter fileWriter;
 
@@ -161,6 +161,7 @@ public class CarbonInputMapperTest extends TestCase {
     @Override public void cleanup(Context context) throws IOException, 
InterruptedException {
       super.cleanup(context);
       fileWriter.close();
+      context.write(new Text(), new Text());
     }
   }
 

Reply via email to