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()); } }