carbondata-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ravipes...@apache.org
Subject carbondata git commit: [CARBONDATA-1799] conf added in testcase
Date Thu, 23 Nov 2017 08:58:54 GMT
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 <rahul.kumar@knoldus.in>
Authored: Wed Nov 22 22:34:28 2017 +0530
Committer: Ravindra Pesala <ravi.pesala@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);
   }
 


Mime
View raw message