[accumulo] branch 1.9 updated: AccumuloFileOutputFormatITs need to look on local filesystem for results written into JUnit provided temp dir. (#654)

[busbey]

This is an automated email from the ASF dual-hosted git repository.

busbey pushed a commit to branch 1.9
in repository https://gitbox.apache.org/repos/asf/accumulo.git


The following commit(s) were added to refs/heads/1.9 by this push:
     new d832765  AccumuloFileOutputFormatITs need to look on local filesystem 
for results written into JUnit provided temp dir. (#654)
d832765 is described below

commit d83276577a41e2c9c7cd4f5bd36ce91aa9631875
Author: Sean Busbey <sean.bus...@gmail.com>
AuthorDate: Thu Sep 20 13:34:30 2018 -0500

    AccumuloFileOutputFormatITs need to look on local filesystem for results 
written into JUnit provided temp dir. (#654)
    
    Before this change the {mapred,mapreduce}.AccumuloFileOutputFormatITs would 
work against a minicluster backed by
    Hadoop's LocalFileSystem, but fail if one followed the instructions for 
testing against a stand alone cluster.
    
    The failure is because in the cluster case the FileSystem we get is for the 
HDFS instance underlying the
    Accumulo cluster, which can't find the folder JUnit created for our test.
---
 .../org/apache/accumulo/test/mapred/AccumuloFileOutputFormatIT.java  | 5 +++--
 .../apache/accumulo/test/mapreduce/AccumuloFileOutputFormatIT.java   | 5 +++--
 2 files changed, 6 insertions(+), 4 deletions(-)

diff --git 
a/test/src/main/java/org/apache/accumulo/test/mapred/AccumuloFileOutputFormatIT.java
 
b/test/src/main/java/org/apache/accumulo/test/mapred/AccumuloFileOutputFormatIT.java
index 7f5fabb..e54d528 100644
--- 
a/test/src/main/java/org/apache/accumulo/test/mapred/AccumuloFileOutputFormatIT.java
+++ 
b/test/src/main/java/org/apache/accumulo/test/mapred/AccumuloFileOutputFormatIT.java
@@ -198,8 +198,9 @@ public class AccumuloFileOutputFormatIT extends 
AccumuloClusterHarness {
       Configuration conf = CachedConfiguration.getInstance();
       DefaultConfiguration acuconf = DefaultConfiguration.getInstance();
       FileSKVIterator sample = RFileOperations.getInstance().newReaderBuilder()
-          .forFile(files[0].toString(), FileSystem.get(conf), 
conf).withTableConfiguration(acuconf)
-          .build().getSample(new SamplerConfigurationImpl(SAMPLER_CONFIG));
+          .forFile(files[0].toString(), FileSystem.getLocal(conf), conf)
+          .withTableConfiguration(acuconf).build()
+          .getSample(new SamplerConfigurationImpl(SAMPLER_CONFIG));
       assertNotNull(sample);
     } else {
       assertEquals(0, files.length);
diff --git 
a/test/src/main/java/org/apache/accumulo/test/mapreduce/AccumuloFileOutputFormatIT.java
 
b/test/src/main/java/org/apache/accumulo/test/mapreduce/AccumuloFileOutputFormatIT.java
index 8b292d0..e299151 100644
--- 
a/test/src/main/java/org/apache/accumulo/test/mapreduce/AccumuloFileOutputFormatIT.java
+++ 
b/test/src/main/java/org/apache/accumulo/test/mapreduce/AccumuloFileOutputFormatIT.java
@@ -212,8 +212,9 @@ public class AccumuloFileOutputFormatIT extends 
AccumuloClusterHarness {
       Configuration conf = CachedConfiguration.getInstance();
       DefaultConfiguration acuconf = DefaultConfiguration.getInstance();
       FileSKVIterator sample = RFileOperations.getInstance().newReaderBuilder()
-          .forFile(files[0].toString(), FileSystem.get(conf), 
conf).withTableConfiguration(acuconf)
-          .build().getSample(new SamplerConfigurationImpl(SAMPLER_CONFIG));
+          .forFile(files[0].toString(), FileSystem.getLocal(conf), conf)
+          .withTableConfiguration(acuconf).build()
+          .getSample(new SamplerConfigurationImpl(SAMPLER_CONFIG));
       assertNotNull(sample);
     } else {
       assertEquals(0, files.length);