You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@carbondata.apache.org by ja...@apache.org on 2017/04/11 00:59:54 UTC
[05/11] incubator-carbondata git commit: FIxed testcase in hadoop
2.7.2
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 <ra...@gmail.com>
Authored: Mon Apr 10 18:55:52 2017 +0530
Committer: ravipesala <ra...@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());
}
}