[GitHub] [accumulo-testing] keith-turner commented on a change in pull request #121: Fix #120 Support non default absolute hdfs paths in cingest bulk

[GitBox <gi...@apache.org>]

keith-turner commented on a change in pull request #121: Fix #120 Support non default absolute hdfs paths in cingest bulk
URL: https://github.com/apache/accumulo-testing/pull/121#discussion_r351280454
 
 

 ##########
 File path: src/main/java/org/apache/accumulo/testing/continuous/BulkIngest.java
 ##########
 @@ -50,13 +51,14 @@
   @Override
   public int run(String[] args) throws Exception {
     String ingestInstanceId = UUID.randomUUID().toString();
+    String bulkPath = args[0];
 
     Job job = Job.getInstance(getConf());
     job.setJobName("BulkIngest_" + ingestInstanceId);
     job.setJarByClass(BulkIngest.class);
     // very important to prevent guava conflicts
     job.getConfiguration().set("mapreduce.job.classloader", "true");
-    FileSystem fs = FileSystem.get(job.getConfiguration());
+    FileSystem fs = FileSystem.get(URI.create(bulkPath), job.getConfiguration());
 
 Review comment:
   Do you know if paths w/o a scheme like `/tmp/bt/1` still work?

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
users@infra.apache.org


With regards,
Apache Git Services