Index: core/src/test/java/org/apache/mahout/clustering/fuzzykmeans/TestFuzzyKmeansClustering.java
===================================================================
--- core/src/test/java/org/apache/mahout/clustering/fuzzykmeans/TestFuzzyKmeansClustering.java	(revision 765750)
+++ core/src/test/java/org/apache/mahout/clustering/fuzzykmeans/TestFuzzyKmeansClustering.java	(working copy)
@@ -210,8 +210,8 @@
       System.out.println("testKFuzzyKMeansMRJob k= " + k);
       // pick k initial cluster centers at random
       JobConf job = new JobConf(FuzzyKMeansDriver.class);
-      FileSystem fs = FileSystem.get(job);
       Path path = new Path("testdata/clusters");
+      FileSystem fs = FileSystem.get(path.toUri(), job);
       if (fs.exists(path)) {
         fs.delete(path, true);
       }
@@ -239,7 +239,7 @@
 
       JobConf conf = new JobConf(FuzzyKMeansDriver.class);
       Path outPath = new Path("output");
-      fs = FileSystem.get(conf);
+      fs = FileSystem.get(outPath.toUri(), conf);
       if (fs.exists(outPath)) {
         fs.delete(outPath, true);
       }
Index: core/src/test/java/org/apache/mahout/clustering/canopy/TestCanopyCreation.java
===================================================================
--- core/src/test/java/org/apache/mahout/clustering/canopy/TestCanopyCreation.java	(revision 765750)
+++ core/src/test/java/org/apache/mahout/clustering/canopy/TestCanopyCreation.java	(working copy)
@@ -478,8 +478,8 @@
     // verify output from sequence file
     JobConf job = new JobConf(
         org.apache.mahout.clustering.canopy.CanopyDriver.class);
-    FileSystem fs = FileSystem.get(job);
     Path path = new Path("output/canopies/part-00000");
+    FileSystem fs = FileSystem.get(path.toUri(), job);
     SequenceFile.Reader reader = new SequenceFile.Reader(fs, path, job);
     Text key = new Text();
     Text value = new Text();
@@ -514,8 +514,8 @@
     // verify output from sequence file
     JobConf job = new JobConf(
         org.apache.mahout.clustering.canopy.CanopyDriver.class);
-    FileSystem fs = FileSystem.get(job);
     Path path = new Path("output/canopies/part-00000");
+    FileSystem fs = FileSystem.get(path.toUri(), job);
     SequenceFile.Reader reader = new SequenceFile.Reader(fs, path, job);
     Text key = new Text();
     Text value = new Text();
@@ -805,8 +805,8 @@
     // verify output from sequence file
     JobConf job = new JobConf(
         org.apache.mahout.clustering.canopy.CanopyDriver.class);
-    FileSystem fs = FileSystem.get(job);
     Path path = new Path("output/canopies/part-00000");
+    FileSystem fs = FileSystem.get(path.toUri(), job);
     SequenceFile.Reader reader = new SequenceFile.Reader(fs, path, job);
     Text key = new Text();
     Text value = new Text();
Index: core/src/test/java/org/apache/mahout/clustering/kmeans/TestKmeansClustering.java
===================================================================
--- core/src/test/java/org/apache/mahout/clustering/kmeans/TestKmeansClustering.java	(revision 765750)
+++ core/src/test/java/org/apache/mahout/clustering/kmeans/TestKmeansClustering.java	(working copy)
@@ -389,8 +389,8 @@
       System.out.println("testKMeansMRJob k= " + k);
       // pick k initial cluster centers at random
       JobConf job = new JobConf(KMeansDriver.class);
-      FileSystem fs = FileSystem.get(job);
       Path path = new Path("testdata/clusters/part-00000");
+      FileSystem fs = FileSystem.get(path.toUri(), job);
     SequenceFile.Writer writer = new SequenceFile.Writer(fs, job, path,
           Text.class, Text.class);
 
Index: core/src/test/java/org/apache/mahout/clustering/meanshift/TestMeanShift.java
===================================================================
--- core/src/test/java/org/apache/mahout/clustering/meanshift/TestMeanShift.java	(revision 765750)
+++ core/src/test/java/org/apache/mahout/clustering/meanshift/TestMeanShift.java	(working copy)
@@ -336,8 +336,8 @@
     MeanShiftCanopyJob.runJob("testdata", "output",
         EuclideanDistanceMeasure.class.getName(), 4, 1, 0.5, 10);
     JobConf conf = new JobConf(MeanShiftCanopyDriver.class);
-    FileSystem fs = FileSystem.get(conf);
     Path outPart = new Path("output/canopies-2/part-00000");
+    FileSystem fs = FileSystem.get(outPart.toUri(), conf);
     SequenceFile.Reader reader = new SequenceFile.Reader(fs, outPart, conf);
     Text key = new Text();
     Text value = new Text();
Index: core/src/test/java/org/apache/mahout/ga/watchmaker/MahoutEvaluatorTest.java
===================================================================
--- core/src/test/java/org/apache/mahout/ga/watchmaker/MahoutEvaluatorTest.java	(revision 765750)
+++ core/src/test/java/org/apache/mahout/ga/watchmaker/MahoutEvaluatorTest.java	(working copy)
@@ -68,8 +68,8 @@
 
   private static void storeLoadPopulation(List<DummyCandidate> population)
       throws IOException {
-    FileSystem fs = FileSystem.get(new Configuration());
     Path f = new Path("build/test.txt");
+    FileSystem fs = FileSystem.get(f.toUri(), new Configuration());
 
     // store the population
     MahoutEvaluator.storePopulation(fs, f, population);
Index: core/src/main/java/org/apache/mahout/clustering/fuzzykmeans/FuzzyKMeansDriver.java
===================================================================
--- core/src/main/java/org/apache/mahout/clustering/fuzzykmeans/FuzzyKMeansDriver.java	(revision 765750)
+++ core/src/main/java/org/apache/mahout/clustering/fuzzykmeans/FuzzyKMeansDriver.java	(working copy)
@@ -165,7 +165,7 @@
 
     try {
       JobClient.runJob(conf);
-      FileSystem fs = FileSystem.get(conf);
+      FileSystem fs = FileSystem.get(outPath.toUri(), conf);
       return isConverged(clustersOut, conf, fs);
     } catch (IOException e) {
       log.warn(e.toString(), e);
Index: core/src/main/java/org/apache/mahout/clustering/dirichlet/DirichletJob.java
===================================================================
--- core/src/main/java/org/apache/mahout/clustering/dirichlet/DirichletJob.java	(revision 765750)
+++ core/src/main/java/org/apache/mahout/clustering/dirichlet/DirichletJob.java	(working copy)
@@ -60,7 +60,7 @@
     // delete the output directory
     JobConf conf = new JobConf(DirichletJob.class);
     Path outPath = new Path(output);
-    FileSystem fs = FileSystem.get(conf);
+    FileSystem fs = FileSystem.get(outPath.toUri(), conf);
     if (fs.exists(outPath)) {
       fs.delete(outPath, true);
     }
Index: core/src/main/java/org/apache/mahout/clustering/dirichlet/DirichletDriver.java
===================================================================
--- core/src/main/java/org/apache/mahout/clustering/dirichlet/DirichletDriver.java	(revision 765750)
+++ core/src/main/java/org/apache/mahout/clustering/dirichlet/DirichletDriver.java	(working copy)
@@ -104,8 +104,9 @@
       IllegalAccessException, FileNotFoundException, IOException {
     DirichletState<Vector> state = createState(modelFactory, numModels, alpha_0);
     JobConf job = new JobConf(KMeansDriver.class);
-    FileSystem fs = FileSystem.get(job);
-    fs.delete(new Path(output), true);
+    Path outPath = new Path(output);
+    FileSystem fs = FileSystem.get(outPath.toUri(), job);
+    fs.delete(outPath, true);
     for (int i = 0; i < numModels; i++) {
       Path path = new Path(stateIn + "/part-" + i);
       SequenceFile.Writer writer = new SequenceFile.Writer(fs, job, path,
Index: core/src/main/java/org/apache/mahout/clustering/dirichlet/DirichletMapper.java
===================================================================
--- core/src/main/java/org/apache/mahout/clustering/dirichlet/DirichletMapper.java	(revision 765750)
+++ core/src/main/java/org/apache/mahout/clustering/dirichlet/DirichletMapper.java	(working copy)
@@ -70,8 +70,8 @@
     try {
       DirichletState<Vector> state = DirichletDriver.createState(modelFactory,
           new Integer(numClusters), new Double(alpha_0));
-      FileSystem fs = FileSystem.get(job);
       Path path = new Path(statePath);
+      FileSystem fs = FileSystem.get(path.toUri(), job);
       FileStatus[] status = fs.listStatus(path);
       for (FileStatus s : status) {
         SequenceFile.Reader reader = new SequenceFile.Reader(fs, s.getPath(),
Index: core/src/main/java/org/apache/mahout/clustering/canopy/CanopyDriver.java
===================================================================
--- core/src/main/java/org/apache/mahout/clustering/canopy/CanopyDriver.java	(revision 765750)
+++ core/src/main/java/org/apache/mahout/clustering/canopy/CanopyDriver.java	(working copy)
@@ -74,7 +74,7 @@
     conf.setOutputFormat(SequenceFileOutputFormat.class);
 
     client.setConf(conf);
-    FileSystem dfs = FileSystem.get(conf);
+    FileSystem dfs = FileSystem.get(outPath.toUri(), conf);
     if (dfs.exists(outPath))
       dfs.delete(outPath, true);
     JobClient.runJob(conf);
Index: core/src/main/java/org/apache/mahout/clustering/canopy/ClusterMapper.java
===================================================================
--- core/src/main/java/org/apache/mahout/clustering/canopy/ClusterMapper.java	(revision 765750)
+++ core/src/main/java/org/apache/mahout/clustering/canopy/ClusterMapper.java	(working copy)
@@ -33,6 +33,7 @@
 import java.io.IOException;
 import java.util.ArrayList;
 import java.util.List;
+import org.slf4j.LoggerFactory;
 
 public class ClusterMapper extends MapReduceBase implements
         Mapper<WritableComparable<?>, Text, Text, Text> {
@@ -64,8 +65,8 @@
     canopies = new ArrayList<Canopy>();
 
     try {
-      FileSystem fs = FileSystem.get(job);
       Path path = new Path(canopyPath + "/part-00000");
+      FileSystem fs = FileSystem.get(path.toUri(), job);
       SequenceFile.Reader reader = new SequenceFile.Reader(fs, path, job);
       try {
         Text key = new Text();
Index: core/src/main/java/org/apache/mahout/clustering/canopy/ClusterDriver.java
===================================================================
--- core/src/main/java/org/apache/mahout/clustering/canopy/ClusterDriver.java	(revision 765750)
+++ core/src/main/java/org/apache/mahout/clustering/canopy/ClusterDriver.java	(working copy)
@@ -75,7 +75,7 @@
     conf.setReducerClass(IdentityReducer.class);
 
     client.setConf(conf);
-    FileSystem dfs = FileSystem.get(conf);
+    FileSystem dfs = FileSystem.get(outPath.toUri(), conf);
     if (dfs.exists(outPath))
       dfs.delete(outPath, true);
     JobClient.runJob(conf);
Index: core/src/main/java/org/apache/mahout/clustering/kmeans/KMeansJob.java
===================================================================
--- core/src/main/java/org/apache/mahout/clustering/kmeans/KMeansJob.java	(revision 765750)
+++ core/src/main/java/org/apache/mahout/clustering/kmeans/KMeansJob.java	(working copy)
@@ -68,7 +68,7 @@
     // delete the output directory
     JobConf conf = new JobConf(KMeansJob.class);
     Path outPath = new Path(output);
-    FileSystem fs = FileSystem.get(conf);
+    FileSystem fs = FileSystem.get(outPath.toUri(), conf);
     if (fs.exists(outPath)) {
       fs.delete(outPath, true);
     }
Index: core/src/main/java/org/apache/mahout/clustering/kmeans/KMeansDriver.java
===================================================================
--- core/src/main/java/org/apache/mahout/clustering/kmeans/KMeansDriver.java	(revision 765750)
+++ core/src/main/java/org/apache/mahout/clustering/kmeans/KMeansDriver.java	(working copy)
@@ -120,7 +120,7 @@
     client.setConf(conf);
     try {
       JobClient.runJob(conf);
-      FileSystem fs = FileSystem.get(conf);
+      FileSystem fs = FileSystem.get(outPath.toUri(), conf);
       return isConverged(clustersOut + "/part-00000", conf, fs);
     } catch (IOException e) {
       log.warn(e.toString(), e);
Index: core/src/main/java/org/apache/mahout/clustering/meanshift/MeanShiftCanopyJob.java
===================================================================
--- core/src/main/java/org/apache/mahout/clustering/meanshift/MeanShiftCanopyJob.java	(revision 765750)
+++ core/src/main/java/org/apache/mahout/clustering/meanshift/MeanShiftCanopyJob.java	(working copy)
@@ -63,7 +63,7 @@
     // delete the output directory
     JobConf conf = new JobConf(MeanShiftCanopyDriver.class);
     Path outPath = new Path(output);
-    FileSystem fs = FileSystem.get(conf);
+    FileSystem fs = FileSystem.get(outPath.toUri(), conf);
     if (fs.exists(outPath)) {
       fs.delete(outPath, true);
     }
Index: core/src/main/java/org/apache/mahout/utils/WeightedDistanceMeasure.java
===================================================================
--- core/src/main/java/org/apache/mahout/utils/WeightedDistanceMeasure.java	(revision 765750)
+++ core/src/main/java/org/apache/mahout/utils/WeightedDistanceMeasure.java	(working copy)
@@ -63,7 +63,7 @@
       ParameteredGeneralizations.configureParameters(this, jobConf);
     }
     try {
-      FileSystem fs = FileSystem.get(jobConf);
+      FileSystem fs = FileSystem.get(weightsFile.get().toUri(), jobConf);
       if (weightsFile.get() != null) {
         Vector weights = (Vector) vectorClass.get().newInstance();
         if (!fs.exists(weightsFile.get())) {
Index: core/src/main/java/org/apache/mahout/classifier/bayes/BayesDriver.java
===================================================================
--- core/src/main/java/org/apache/mahout/classifier/bayes/BayesDriver.java	(revision 765750)
+++ core/src/main/java/org/apache/mahout/classifier/bayes/BayesDriver.java	(working copy)
@@ -65,8 +65,8 @@
    */
   public static void runJob(String input, String output, int gramSize) throws IOException {
     JobConf conf = new JobConf(BayesDriver.class);
-    FileSystem dfs = FileSystem.get(conf);
     Path outPath = new Path(output);
+    FileSystem dfs = FileSystem.get(outPath.toUri(), conf);
     if (dfs.exists(outPath))
       dfs.delete(outPath, true);
 
Index: core/src/main/java/org/apache/mahout/classifier/bayes/common/BayesWeightSummerDriver.java
===================================================================
--- core/src/main/java/org/apache/mahout/classifier/bayes/common/BayesWeightSummerDriver.java	(revision 765750)
+++ core/src/main/java/org/apache/mahout/classifier/bayes/common/BayesWeightSummerDriver.java	(working copy)
@@ -77,7 +77,7 @@
     conf.setCombinerClass(BayesWeightSummerReducer.class);
     conf.setReducerClass(BayesWeightSummerReducer.class);    
     conf.setOutputFormat(BayesWeightSummerOutputFormat.class);
-    FileSystem dfs = FileSystem.get(conf);
+    FileSystem dfs = FileSystem.get(outPath.toUri(), conf);
     if (dfs.exists(outPath))
       dfs.delete(outPath, true);
     client.setConf(conf);
Index: core/src/main/java/org/apache/mahout/classifier/bayes/common/BayesFeatureDriver.java
===================================================================
--- core/src/main/java/org/apache/mahout/classifier/bayes/common/BayesFeatureDriver.java	(revision 765750)
+++ core/src/main/java/org/apache/mahout/classifier/bayes/common/BayesFeatureDriver.java	(working copy)
@@ -86,7 +86,7 @@
              "org.apache.hadoop.io.serializer.JavaSerialization,org.apache.hadoop.io.serializer.WritableSerialization"); 
     // Dont ever forget this. People should keep track of how hadoop conf parameters and make or break a piece of code
 
-    FileSystem dfs = FileSystem.get(conf);
+    FileSystem dfs = FileSystem.get(outPath.toUri(), conf);
     if (dfs.exists(outPath))
       dfs.delete(outPath, true);
 
Index: core/src/main/java/org/apache/mahout/classifier/bayes/common/BayesTfIdfDriver.java
===================================================================
--- core/src/main/java/org/apache/mahout/classifier/bayes/common/BayesTfIdfDriver.java	(revision 765750)
+++ core/src/main/java/org/apache/mahout/classifier/bayes/common/BayesTfIdfDriver.java	(working copy)
@@ -91,7 +91,7 @@
     conf.set("io.serializations",
              "org.apache.hadoop.io.serializer.JavaSerialization,org.apache.hadoop.io.serializer.WritableSerialization");
     // Dont ever forget this. People should keep track of how hadoop conf parameters and make or break a piece of code
-    FileSystem dfs = FileSystem.get(conf);
+    FileSystem dfs = FileSystem.get(outPath.toUri(), conf);
     if (dfs.exists(outPath))
       dfs.delete(outPath, true);
 
Index: core/src/main/java/org/apache/mahout/classifier/bayes/BayesThetaNormalizerDriver.java
===================================================================
--- core/src/main/java/org/apache/mahout/classifier/bayes/BayesThetaNormalizerDriver.java	(revision 765750)
+++ core/src/main/java/org/apache/mahout/classifier/bayes/BayesThetaNormalizerDriver.java	(working copy)
@@ -89,7 +89,7 @@
              "org.apache.hadoop.io.serializer.JavaSerialization,org.apache.hadoop.io.serializer.WritableSerialization");
     // Dont ever forget this. People should keep track of how hadoop conf parameters and make or break a piece of code
     
-    FileSystem dfs = FileSystem.get(conf);
+    FileSystem dfs = FileSystem.get(outPath.toUri(), conf);
     if (dfs.exists(outPath))
       dfs.delete(outPath, true);
 
Index: core/src/main/java/org/apache/mahout/classifier/cbayes/CBayesNormalizedWeightDriver.java
===================================================================
--- core/src/main/java/org/apache/mahout/classifier/cbayes/CBayesNormalizedWeightDriver.java	(revision 765750)
+++ core/src/main/java/org/apache/mahout/classifier/cbayes/CBayesNormalizedWeightDriver.java	(working copy)
@@ -89,7 +89,7 @@
     conf.set("io.serializations",
              "org.apache.hadoop.io.serializer.JavaSerialization,org.apache.hadoop.io.serializer.WritableSerialization");
     // Dont ever forget this. People should keep track of how hadoop conf parameters and make or break a piece of code
-    FileSystem dfs = FileSystem.get(conf);
+    FileSystem dfs = FileSystem.get(outPath.toUri(), conf);
     if (dfs.exists(outPath))
       dfs.delete(outPath, true);
 
Index: core/src/main/java/org/apache/mahout/classifier/cbayes/CBayesDriver.java
===================================================================
--- core/src/main/java/org/apache/mahout/classifier/cbayes/CBayesDriver.java	(revision 765750)
+++ core/src/main/java/org/apache/mahout/classifier/cbayes/CBayesDriver.java	(working copy)
@@ -65,8 +65,8 @@
    */
   public static void runJob(String input, String output, int gramSize) throws IOException {
     JobConf conf = new JobConf(CBayesDriver.class);
-    FileSystem dfs = FileSystem.get(conf);
     Path outPath = new Path(output);
+    FileSystem dfs = FileSystem.get(outPath.toUri(), conf);
     if (dfs.exists(outPath))
       dfs.delete(outPath, true);
 
Index: core/src/main/java/org/apache/mahout/classifier/cbayes/CBayesThetaDriver.java
===================================================================
--- core/src/main/java/org/apache/mahout/classifier/cbayes/CBayesThetaDriver.java	(revision 765750)
+++ core/src/main/java/org/apache/mahout/classifier/cbayes/CBayesThetaDriver.java	(working copy)
@@ -91,7 +91,7 @@
     conf.set("io.serializations",
              "org.apache.hadoop.io.serializer.JavaSerialization,org.apache.hadoop.io.serializer.WritableSerialization");
     // Dont ever forget this. People should keep track of how hadoop conf parameters and make or break a piece of code
-    FileSystem dfs = FileSystem.get(conf);
+    FileSystem dfs = FileSystem.get(outPath.toUri(), conf);
     if (dfs.exists(outPath))
       dfs.delete(outPath, true);
 
Index: core/src/main/java/org/apache/mahout/classifier/cbayes/CBayesThetaNormalizerDriver.java
===================================================================
--- core/src/main/java/org/apache/mahout/classifier/cbayes/CBayesThetaNormalizerDriver.java	(revision 765750)
+++ core/src/main/java/org/apache/mahout/classifier/cbayes/CBayesThetaNormalizerDriver.java	(working copy)
@@ -90,7 +90,7 @@
              "org.apache.hadoop.io.serializer.JavaSerialization,org.apache.hadoop.io.serializer.WritableSerialization");
     // Dont ever forget this. People should keep track of how hadoop conf parameters and make or break a piece of code
     
-    FileSystem dfs = FileSystem.get(conf);
+    FileSystem dfs = FileSystem.get(outPath.toUri(), conf);
     if (dfs.exists(outPath))
       dfs.delete(outPath, true);
 
Index: core/src/main/java/org/apache/mahout/classifier/Classify.java
===================================================================
--- core/src/main/java/org/apache/mahout/classifier/Classify.java	(revision 765750)
+++ core/src/main/java/org/apache/mahout/classifier/Classify.java	(working copy)
@@ -106,7 +106,7 @@
     modelPaths.put("thetaNormalizer", new Path(modelBasePath + "/trainer-thetaNormalizer/part-*"));
     modelPaths.put("weight", new Path(modelBasePath + "/trainer-tfIdf/trainer-tfIdf/part-*"));
 
-    FileSystem fs = FileSystem.get(conf);
+    FileSystem fs = FileSystem.get((new Path(modelBasePath)).toUri(), conf);
 
     log.info("Loading model from: {}", modelPaths);
 
Index: core/src/main/java/org/apache/mahout/ga/watchmaker/MahoutEvaluator.java
===================================================================
--- core/src/main/java/org/apache/mahout/ga/watchmaker/MahoutEvaluator.java	(revision 765750)
+++ core/src/main/java/org/apache/mahout/ga/watchmaker/MahoutEvaluator.java	(working copy)
@@ -61,10 +61,10 @@
       List<Double> evaluations) throws IOException {
     JobConf conf = new JobConf(MahoutEvaluator.class);
     FileSystem fs = FileSystem.get(conf);
-
     Path inpath = prepareInput(fs, population);
     Path outpath = OutputUtils.prepareOutput(fs);
 
+
     configureJob(conf, evaluator, inpath, outpath);
     JobClient.runJob(conf);
 
Index: core/src/main/java/org/apache/mahout/cf/taste/hadoop/RecommenderMapper.java
===================================================================
--- core/src/main/java/org/apache/mahout/cf/taste/hadoop/RecommenderMapper.java	(revision 765751)
+++ core/src/main/java/org/apache/mahout/cf/taste/hadoop/RecommenderMapper.java	(working copy)
@@ -82,10 +82,11 @@
     String recommenderClassName = jobConf.get(RECOMMENDER_CLASS_NAME);
     FileDataModel fileDataModel;
     try {
-      FileSystem fs = FileSystem.get(jobConf);
+      Path dataModelPath = new Path(dataModelFile);
+      FileSystem fs = FileSystem.get(dataModelPath.toUri(), jobConf);
       File tempDataFile = File.createTempFile("mahout-taste-hadoop", "txt");
       tempDataFile.deleteOnExit();
-      fs.copyToLocalFile(new Path(dataModelFile), new Path(tempDataFile.getAbsolutePath()));
+      fs.copyToLocalFile(dataModelPath, new Path(tempDataFile.getAbsolutePath()));
       fileDataModel = new FileDataModel(tempDataFile);
     } catch (IOException ioe) {
       throw new RuntimeException(ioe);
Index: core/src/main/java/org/apache/mahout/cf/taste/hadoop/RecommenderJob.java
===================================================================
--- core/src/main/java/org/apache/mahout/cf/taste/hadoop/RecommenderJob.java	(revision 765751)
+++ core/src/main/java/org/apache/mahout/cf/taste/hadoop/RecommenderJob.java	(working copy)
@@ -80,7 +80,7 @@
 
     JobConf jobConf = new JobConf(RecommenderJob.class);
 
-    FileSystem fs = FileSystem.get(jobConf);
+    FileSystem fs = FileSystem.get(outputPathPath.toUri(), jobConf);
     if (fs.exists(outputPathPath)) {
       fs.delete(outputPathPath, true);
     }
Index: core/src/main/java/org/apache/mahout/cf/taste/hadoop/SlopeOneDiffsToAveragesJob.java
===================================================================
--- core/src/main/java/org/apache/mahout/cf/taste/hadoop/SlopeOneDiffsToAveragesJob.java	(revision 765751)
+++ core/src/main/java/org/apache/mahout/cf/taste/hadoop/SlopeOneDiffsToAveragesJob.java	(working copy)
@@ -51,7 +51,7 @@
 
     JobConf jobConf = new JobConf(SlopeOnePrefsToDiffsJob.class);
 
-    FileSystem fs = FileSystem.get(jobConf);
+    FileSystem fs = FileSystem.get(outputPathPath.toUri(), jobConf);
     if (fs.exists(outputPathPath)) {
       fs.delete(outputPathPath, true);
     }
Index: core/src/main/java/org/apache/mahout/cf/taste/hadoop/SlopeOnePrefsToDiffsJob.java
===================================================================
--- core/src/main/java/org/apache/mahout/cf/taste/hadoop/SlopeOnePrefsToDiffsJob.java	(revision 765751)
+++ core/src/main/java/org/apache/mahout/cf/taste/hadoop/SlopeOnePrefsToDiffsJob.java	(working copy)
@@ -52,7 +52,7 @@
 
     JobConf jobConf = new JobConf(SlopeOnePrefsToDiffsJob.class);
 
-    FileSystem fs = FileSystem.get(jobConf);
+    FileSystem fs = FileSystem.get(outputPathPath.toUri(), jobConf);
     if (fs.exists(outputPathPath)) {
       fs.delete(outputPathPath, true);
     }
Index: examples/src/test/java/org/apache/mahout/ga/watchmaker/cd/DataLineTest.java
===================================================================
--- examples/src/test/java/org/apache/mahout/ga/watchmaker/cd/DataLineTest.java	(revision 765750)
+++ examples/src/test/java/org/apache/mahout/ga/watchmaker/cd/DataLineTest.java	(working copy)
@@ -31,8 +31,8 @@
       "852781,M,18.61,20.25,122.1,1094,0.0944,0.1066,0.149,0.07731,0.1697,0.05699,0.8529,1.849,5.632,93.54,0.01075,0.02722,0.05081,0.01911,0.02293,0.004217,21.31,27.26,139.9,1403,0.1338,0.2117,0.3446,0.149,0.2341,0.07421" };
 
   public void testSet() throws Exception {
-    FileSystem fs = FileSystem.get(new Configuration());
     Path inpath = new Path("target/test-classes/wdbc");
+    FileSystem fs = FileSystem.get(inpath.toUri(), new Configuration());
     DataSet dataset = FileInfoParser.parseFile(fs, inpath);
     DataSet.initialize(dataset);
     
Index: examples/src/test/java/org/apache/mahout/ga/watchmaker/cd/FileInfosDatasetTest.java
===================================================================
--- examples/src/test/java/org/apache/mahout/ga/watchmaker/cd/FileInfosDatasetTest.java	(revision 765750)
+++ examples/src/test/java/org/apache/mahout/ga/watchmaker/cd/FileInfosDatasetTest.java	(working copy)
@@ -31,8 +31,8 @@
 public class FileInfosDatasetTest extends TestCase {
 
   public void testRanges() throws IOException {
-    FileSystem fs = FileSystem.get(new Configuration());
     Path inpath = new Path("target/test-classes/wdbc");
+    FileSystem fs = FileSystem.get(inpath.toUri(), new Configuration());
     
     DataSet dataset = FileInfoParser.parseFile(fs, inpath);
     DataSet.initialize(dataset);
Index: examples/src/test/java/org/apache/mahout/ga/watchmaker/cd/tool/CDInfosToolTest.java
===================================================================
--- examples/src/test/java/org/apache/mahout/ga/watchmaker/cd/tool/CDInfosToolTest.java	(revision 765750)
+++ examples/src/test/java/org/apache/mahout/ga/watchmaker/cd/tool/CDInfosToolTest.java	(working copy)
@@ -164,8 +164,8 @@
     Object[][] descriptions = randomDescriptions(descriptors);
 
     // random dataset
-    FileSystem fs = FileSystem.get(new Configuration());
     Path inpath = new Path("input");
+    FileSystem fs = FileSystem.get(inpath.toUri(), new Configuration());
     if (fs.exists(inpath)) {
       fs.delete(inpath, true);
     }
Index: examples/src/main/java/org/apache/mahout/clustering/syntheticcontrol/dirichlet/Job.java
===================================================================
--- examples/src/main/java/org/apache/mahout/clustering/syntheticcontrol/dirichlet/Job.java	(revision 765750)
+++ examples/src/main/java/org/apache/mahout/clustering/syntheticcontrol/dirichlet/Job.java	(working copy)
@@ -79,7 +79,7 @@
     // delete the output directory
     JobConf conf = new JobConf(DirichletJob.class);
     Path outPath = new Path(output);
-    FileSystem fs = FileSystem.get(conf);
+    FileSystem fs = FileSystem.get(outPath.toUri(), conf);
     if (fs.exists(outPath)) {
       fs.delete(outPath, true);
     }
Index: examples/src/main/java/org/apache/mahout/clustering/syntheticcontrol/canopy/Job.java
===================================================================
--- examples/src/main/java/org/apache/mahout/clustering/syntheticcontrol/canopy/Job.java	(revision 765750)
+++ examples/src/main/java/org/apache/mahout/clustering/syntheticcontrol/canopy/Job.java	(working copy)
@@ -66,7 +66,7 @@
 
     Path outPath = new Path(output);
     client.setConf(conf);
-    FileSystem dfs = FileSystem.get(conf);
+    FileSystem dfs = FileSystem.get(outPath.toUri(), conf);
     if (dfs.exists(outPath))
       dfs.delete(outPath, true);
     InputDriver.runJob(input, output + "/data");
Index: examples/src/main/java/org/apache/mahout/clustering/syntheticcontrol/kmeans/Job.java
===================================================================
--- examples/src/main/java/org/apache/mahout/clustering/syntheticcontrol/kmeans/Job.java	(revision 765750)
+++ examples/src/main/java/org/apache/mahout/clustering/syntheticcontrol/kmeans/Job.java	(working copy)
@@ -26,6 +26,8 @@
 import org.apache.mahout.clustering.syntheticcontrol.canopy.InputDriver;
 
 import java.io.IOException;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 public class Job {
   private Job() {
@@ -73,7 +75,7 @@
 
     Path outPath = new Path(output);
     client.setConf(conf);
-    FileSystem dfs = FileSystem.get(conf);
+    FileSystem dfs = FileSystem.get(outPath.toUri(), conf);
     if (dfs.exists(outPath))
       dfs.delete(outPath, true);
     InputDriver.runJob(input, output + "/data");
Index: examples/src/main/java/org/apache/mahout/clustering/syntheticcontrol/meanshift/Job.java
===================================================================
--- examples/src/main/java/org/apache/mahout/clustering/syntheticcontrol/meanshift/Job.java	(revision 765750)
+++ examples/src/main/java/org/apache/mahout/clustering/syntheticcontrol/meanshift/Job.java	(working copy)
@@ -73,7 +73,7 @@
 
     Path outPath = new Path(output);
     client.setConf(conf);
-    FileSystem dfs = FileSystem.get(conf);
+    FileSystem dfs = FileSystem.get(outPath.toUri(), conf);
     if (dfs.exists(outPath))
       dfs.delete(outPath, true);
     InputDriver.runJob(input, output + "/data");
Index: examples/src/main/java/org/apache/mahout/classifier/bayes/TestClassifier.java
===================================================================
--- examples/src/main/java/org/apache/mahout/classifier/bayes/TestClassifier.java	(revision 765750)
+++ examples/src/main/java/org/apache/mahout/classifier/bayes/TestClassifier.java	(working copy)
@@ -107,7 +107,7 @@
     modelPaths.put("thetaNormalizer", new Path(modelBasePath + "/trainer-thetaNormalizer/part-*"));
     modelPaths.put("weight", new Path(modelBasePath + "/trainer-tfIdf/trainer-tfIdf/part-*"));
 
-    FileSystem fs = FileSystem.get(conf);
+    FileSystem fs = FileSystem.get((new Path(modelBasePath)).toUri(), conf);
 
     log.info("Loading model from: {}", modelPaths);
 
Index: examples/src/main/java/org/apache/mahout/classifier/bayes/WikipediaDatasetCreatorDriver.java
===================================================================
--- examples/src/main/java/org/apache/mahout/classifier/bayes/WikipediaDatasetCreatorDriver.java	(revision 765750)
+++ examples/src/main/java/org/apache/mahout/classifier/bayes/WikipediaDatasetCreatorDriver.java	(working copy)
@@ -88,7 +88,7 @@
              "org.apache.hadoop.io.serializer.JavaSerialization,org.apache.hadoop.io.serializer.WritableSerialization");
     // Dont ever forget this. People should keep track of how hadoop conf parameters and make or break a piece of code
 
-    FileSystem dfs = FileSystem.get(conf);
+    FileSystem dfs = FileSystem.get(outPath.toUri(), conf);
     if (dfs.exists(outPath))
       dfs.delete(outPath, true);
 
Index: examples/src/main/java/org/apache/mahout/ga/watchmaker/cd/hadoop/CDMahoutEvaluator.java
===================================================================
--- examples/src/main/java/org/apache/mahout/ga/watchmaker/cd/hadoop/CDMahoutEvaluator.java	(revision 765750)
+++ examples/src/main/java/org/apache/mahout/ga/watchmaker/cd/hadoop/CDMahoutEvaluator.java	(working copy)
@@ -66,7 +66,7 @@
       Path inpath, List<CDFitness> evaluations, DatasetSplit split)
       throws IOException {
     JobConf conf = new JobConf(CDMahoutEvaluator.class);
-    FileSystem fs = FileSystem.get(conf);
+    FileSystem fs = FileSystem.get(inpath.toUri(), conf);
 
     // check the input
     if (!fs.exists(inpath) || !fs.getFileStatus(inpath).isDir())
@@ -88,7 +88,7 @@
    */
   public static void initializeDataSet(Path inpath) throws IOException {
     JobConf conf = new JobConf(CDMahoutEvaluator.class);
-    FileSystem fs = FileSystem.get(conf);
+    FileSystem fs = FileSystem.get(inpath.toUri(), conf);
 
     // Initialize the dataset
     DataSet.initialize(FileInfoParser.parseFile(fs, inpath));
Index: examples/src/main/java/org/apache/mahout/ga/watchmaker/cd/tool/CDInfosTool.java
===================================================================
--- examples/src/main/java/org/apache/mahout/ga/watchmaker/cd/tool/CDInfosTool.java	(revision 765750)
+++ examples/src/main/java/org/apache/mahout/ga/watchmaker/cd/tool/CDInfosTool.java	(working copy)
@@ -68,7 +68,7 @@
   public static void gatherInfos(Descriptors descriptors, Path inpath,
       List<String> descriptions) throws IOException {
     JobConf conf = new JobConf(CDInfosTool.class);
-    FileSystem fs = FileSystem.get(conf);
+    FileSystem fs = FileSystem.get(inpath.toUri(), conf);
 
     // check the input
     if (!fs.exists(inpath) || !fs.getFileStatus(inpath).isDir())
@@ -211,8 +211,8 @@
       throw new IllegalArgumentException();
     }
 
-    FileSystem fs = FileSystem.get(new Configuration());
     Path inpath = new Path(args[0]);
+    FileSystem fs = FileSystem.get(inpath.toUri(), new Configuration());
 
     log.info("Loading Descriptors...");
     Descriptors descriptors = loadDescriptors(fs, inpath);