carbondata-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jack...@apache.org
Subject [05/11] incubator-carbondata git commit: FIxed testcase in hadoop 2.7.2
Date Tue, 11 Apr 2017 00:59:54 GMT
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/12-dev
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