carbondata-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chenliang...@apache.org
Subject [1/2] incubator-carbondata git commit: FIxed testcase in hadoop 2.7.2
Date Mon, 10 Apr 2017 16:10:55 GMT
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.pesala@gmail.com>
Authored: Mon Apr 10 18:55:52 2017 +0530
Committer: ravipesala <ravi.pesala@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());
     }
   }
 


Mime
View raw message