You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@carbondata.apache.org by ra...@apache.org on 2017/11/23 08:58:54 UTC
carbondata git commit: [CARBONDATA-1799] conf added in testcase
Repository: carbondata
Updated Branches:
refs/heads/master 472cf6761 -> 5a3efdbbe
[CARBONDATA-1799] conf added in testcase
This closes #1555
Project: http://git-wip-us.apache.org/repos/asf/carbondata/repo
Commit: http://git-wip-us.apache.org/repos/asf/carbondata/commit/5a3efdbb
Tree: http://git-wip-us.apache.org/repos/asf/carbondata/tree/5a3efdbb
Diff: http://git-wip-us.apache.org/repos/asf/carbondata/diff/5a3efdbb
Branch: refs/heads/master
Commit: 5a3efdbbec6b56b01ffd748a6841a95a85c7dd7d
Parents: 472cf67
Author: rahulforallp <ra...@knoldus.in>
Authored: Wed Nov 22 22:34:28 2017 +0530
Committer: Ravindra Pesala <ra...@gmail.com>
Committed: Thu Nov 23 14:28:36 2017 +0530
----------------------------------------------------------------------
.../org/apache/carbondata/hadoop/ft/CarbonInputMapperTest.java | 5 ++++-
1 file changed, 4 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/carbondata/blob/5a3efdbb/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 1ed8c5c..9d469aa 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
@@ -187,7 +187,9 @@ public class CarbonInputMapperTest extends TestCase {
private void runJob(String outPath, CarbonProjection projection, Expression filter)
throws Exception {
- Job job = Job.getInstance(new Configuration());
+ Configuration configuration = new Configuration();
+ configuration.set("mapreduce.cluster.local.dir", new File(outPath + "1").getCanonicalPath());
+ Job job = Job.getInstance(configuration);
job.setJarByClass(CarbonInputMapperTest.class);
job.setOutputKeyClass(Text.class);
job.setOutputValueClass(IntWritable.class);
@@ -210,6 +212,7 @@ public class CarbonInputMapperTest extends TestCase {
CarbonUtil.deleteFoldersAndFiles(new File(outPath + "1"));
FileOutputFormat.setOutputPath(job, new Path(outPath + "1"));
job.getConfiguration().set("outpath", outPath);
+ job.getConfiguration().set("query.id", String.valueOf(System.nanoTime()));
boolean status = job.waitForCompletion(true);
}