mahout-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dfili...@apache.org
Subject svn commit: r1491265 [1/2] - in /mahout/trunk: ./ core/src/main/java/org/apache/mahout/cf/taste/hadoop/als/ core/src/main/java/org/apache/mahout/cf/taste/impl/recommender/svd/ core/src/main/java/org/apache/mahout/cf/taste/impl/similarity/precompute/ co...
Date Sun, 09 Jun 2013 18:50:05 GMT
Author: dfilimon
Date: Sun Jun  9 18:50:03 2013
New Revision: 1491265

URL: http://svn.apache.org/r1491265
Log:
MAHOUT-1211: Disabled swallowing of IOExceptions is Closeables.close for writers


Modified:
    mahout/trunk/CHANGELOG
    mahout/trunk/core/src/main/java/org/apache/mahout/cf/taste/hadoop/als/FactorizationEvaluator.java
    mahout/trunk/core/src/main/java/org/apache/mahout/cf/taste/hadoop/als/ParallelALSFactorizationJob.java
    mahout/trunk/core/src/main/java/org/apache/mahout/cf/taste/impl/recommender/svd/FilePersistenceStrategy.java
    mahout/trunk/core/src/main/java/org/apache/mahout/cf/taste/impl/similarity/precompute/FileSimilarItemsWriter.java
    mahout/trunk/core/src/main/java/org/apache/mahout/cf/taste/impl/similarity/precompute/MultithreadedBatchItemSimilarities.java
    mahout/trunk/core/src/main/java/org/apache/mahout/classifier/df/DFUtils.java
    mahout/trunk/core/src/main/java/org/apache/mahout/classifier/df/mapreduce/Classifier.java
    mahout/trunk/core/src/main/java/org/apache/mahout/classifier/df/tools/UDistrib.java
    mahout/trunk/core/src/main/java/org/apache/mahout/classifier/naivebayes/BayesUtils.java
    mahout/trunk/core/src/main/java/org/apache/mahout/classifier/naivebayes/NaiveBayesModel.java
    mahout/trunk/core/src/main/java/org/apache/mahout/classifier/sequencelearning/hmm/BaumWelchTrainer.java
    mahout/trunk/core/src/main/java/org/apache/mahout/classifier/sequencelearning/hmm/RandomSequenceGenerator.java
    mahout/trunk/core/src/main/java/org/apache/mahout/classifier/sequencelearning/hmm/ViterbiEvaluator.java
    mahout/trunk/core/src/main/java/org/apache/mahout/classifier/sgd/ModelSerializer.java
    mahout/trunk/core/src/main/java/org/apache/mahout/clustering/canopy/CanopyDriver.java
    mahout/trunk/core/src/main/java/org/apache/mahout/clustering/classify/ClusterClassifier.java
    mahout/trunk/core/src/main/java/org/apache/mahout/clustering/kmeans/RandomSeedGenerator.java
    mahout/trunk/core/src/main/java/org/apache/mahout/clustering/meanshift/MeanShiftCanopyDriver.java
    mahout/trunk/core/src/main/java/org/apache/mahout/clustering/spectral/common/VectorCache.java
    mahout/trunk/core/src/main/java/org/apache/mahout/clustering/streaming/mapreduce/StreamingKMeansUtilsMR.java
    mahout/trunk/core/src/main/java/org/apache/mahout/common/HadoopUtil.java
    mahout/trunk/core/src/main/java/org/apache/mahout/fpm/pfpgrowth/FPGrowthDriver.java
    mahout/trunk/core/src/main/java/org/apache/mahout/math/hadoop/decomposer/DistributedLanczosSolver.java
    mahout/trunk/core/src/main/java/org/apache/mahout/math/hadoop/decomposer/EigenVerificationJob.java
    mahout/trunk/core/src/main/java/org/apache/mahout/math/hadoop/decomposer/HdfsBackedLanczosState.java
    mahout/trunk/core/src/main/java/org/apache/mahout/math/hadoop/similarity/cooccurrence/Vectors.java
    mahout/trunk/core/src/main/java/org/apache/mahout/math/hadoop/stochasticsvd/qr/QRFirstStep.java
    mahout/trunk/core/src/main/java/org/apache/mahout/vectorizer/DictionaryVectorizer.java
    mahout/trunk/core/src/main/java/org/apache/mahout/vectorizer/tfidf/TFIDFConverter.java
    mahout/trunk/core/src/test/java/org/apache/mahout/classifier/df/mapreduce/partial/PartialBuilderTest.java
    mahout/trunk/core/src/test/java/org/apache/mahout/classifier/naivebayes/NaiveBayesTest.java
    mahout/trunk/core/src/test/java/org/apache/mahout/classifier/sgd/ModelSerializerTest.java
    mahout/trunk/core/src/test/java/org/apache/mahout/clustering/ClusteringTestUtils.java
    mahout/trunk/core/src/test/java/org/apache/mahout/clustering/dirichlet/TestMapReduce.java
    mahout/trunk/core/src/test/java/org/apache/mahout/clustering/fuzzykmeans/TestFuzzyKmeansClustering.java
    mahout/trunk/core/src/test/java/org/apache/mahout/clustering/kmeans/TestKmeansClustering.java
    mahout/trunk/core/src/test/java/org/apache/mahout/common/MahoutTestCase.java
    mahout/trunk/core/src/test/java/org/apache/mahout/fpm/pfpgrowth/FPGrowthTest.java
    mahout/trunk/core/src/test/java/org/apache/mahout/fpm/pfpgrowth/FPGrowthTest2.java
    mahout/trunk/core/src/test/java/org/apache/mahout/fpm/pfpgrowth/PFPGrowthRetailDataTest.java
    mahout/trunk/core/src/test/java/org/apache/mahout/fpm/pfpgrowth/PFPGrowthRetailDataTest2.java
    mahout/trunk/core/src/test/java/org/apache/mahout/fpm/pfpgrowth/PFPGrowthRetailDataTestVs.java
    mahout/trunk/core/src/test/java/org/apache/mahout/fpm/pfpgrowth/PFPGrowthSynthDataTest2.java
    mahout/trunk/core/src/test/java/org/apache/mahout/fpm/pfpgrowth/PFPGrowthTest.java
    mahout/trunk/core/src/test/java/org/apache/mahout/fpm/pfpgrowth/PFPGrowthTest2.java
    mahout/trunk/core/src/test/java/org/apache/mahout/math/MatrixWritableTest.java
    mahout/trunk/core/src/test/java/org/apache/mahout/math/VectorWritableTest.java
    mahout/trunk/core/src/test/java/org/apache/mahout/math/hadoop/MathHelper.java
    mahout/trunk/core/src/test/java/org/apache/mahout/math/hadoop/stochasticsvd/LocalSSVDPCADenseTest.java
    mahout/trunk/core/src/test/java/org/apache/mahout/math/hadoop/stochasticsvd/LocalSSVDSolverSparseSequentialTest.java
    mahout/trunk/core/src/test/java/org/apache/mahout/math/stats/entropy/ConditionalEntropyTest.java
    mahout/trunk/core/src/test/java/org/apache/mahout/math/stats/entropy/EntropyTest.java
    mahout/trunk/core/src/test/java/org/apache/mahout/math/stats/entropy/InformationGainRatioTest.java
    mahout/trunk/core/src/test/java/org/apache/mahout/math/stats/entropy/InformationGainTest.java
    mahout/trunk/core/src/test/java/org/apache/mahout/vectorizer/DictionaryVectorizerTest.java
    mahout/trunk/core/src/test/java/org/apache/mahout/vectorizer/DocumentProcessorTest.java
    mahout/trunk/core/src/test/java/org/apache/mahout/vectorizer/EncodedVectorsFromSequenceFilesTest.java
    mahout/trunk/core/src/test/java/org/apache/mahout/vectorizer/SparseVectorsFromSequenceFilesTest.java
    mahout/trunk/core/src/test/java/org/apache/mahout/vectorizer/collocations/llr/GramKeyTest.java
    mahout/trunk/examples/src/main/java/org/apache/mahout/cf/taste/example/bookcrossing/BookCrossingDataModel.java
    mahout/trunk/examples/src/main/java/org/apache/mahout/cf/taste/example/email/MailToPrefsDriver.java
    mahout/trunk/examples/src/main/java/org/apache/mahout/cf/taste/example/grouplens/GroupLensDataModel.java
    mahout/trunk/examples/src/main/java/org/apache/mahout/cf/taste/example/kddcup/ToCSV.java
    mahout/trunk/examples/src/main/java/org/apache/mahout/cf/taste/example/kddcup/track1/Track1Runner.java
    mahout/trunk/examples/src/main/java/org/apache/mahout/cf/taste/example/kddcup/track1/svd/Track1SVDRunner.java
    mahout/trunk/examples/src/main/java/org/apache/mahout/cf/taste/example/kddcup/track2/Track2Runner.java
    mahout/trunk/examples/src/main/java/org/apache/mahout/cf/taste/hadoop/example/als/netflix/NetflixDatasetConverter.java
    mahout/trunk/examples/src/main/java/org/apache/mahout/classifier/sgd/TrainLogistic.java
    mahout/trunk/examples/src/main/java/org/apache/mahout/clustering/display/DisplayClustering.java
    mahout/trunk/examples/src/main/java/org/apache/mahout/clustering/display/DisplaySpectralKMeans.java
    mahout/trunk/examples/src/main/java/org/apache/mahout/clustering/minhash/LastfmDataConverter.java
    mahout/trunk/integration/src/main/java/org/apache/mahout/benchmark/SerializationBenchmark.java
    mahout/trunk/integration/src/main/java/org/apache/mahout/clustering/lda/LDAPrintTopics.java
    mahout/trunk/integration/src/main/java/org/apache/mahout/text/SequenceFilesFromLuceneStorage.java
    mahout/trunk/integration/src/main/java/org/apache/mahout/text/SequenceFilesFromMailArchives.java
    mahout/trunk/integration/src/main/java/org/apache/mahout/text/wikipedia/WikipediaXmlSplitter.java
    mahout/trunk/integration/src/main/java/org/apache/mahout/utils/SequenceFileDumper.java
    mahout/trunk/integration/src/main/java/org/apache/mahout/utils/clustering/ClusterDumper.java
    mahout/trunk/integration/src/main/java/org/apache/mahout/utils/vectors/RowIdJob.java
    mahout/trunk/integration/src/main/java/org/apache/mahout/utils/vectors/VectorDumper.java
    mahout/trunk/integration/src/main/java/org/apache/mahout/utils/vectors/arff/Driver.java
    mahout/trunk/integration/src/main/java/org/apache/mahout/utils/vectors/io/DelimitedTermInfoWriter.java
    mahout/trunk/integration/src/main/java/org/apache/mahout/utils/vectors/io/SequenceFileVectorWriter.java
    mahout/trunk/integration/src/main/java/org/apache/mahout/utils/vectors/io/TextualVectorWriter.java
    mahout/trunk/integration/src/main/java/org/apache/mahout/utils/vectors/lucene/ClusterLabels.java
    mahout/trunk/integration/src/test/java/org/apache/mahout/clustering/TestClusterDumper.java
    mahout/trunk/integration/src/test/java/org/apache/mahout/text/SequenceFilesFromMailArchivesTest.java
    mahout/trunk/integration/src/test/java/org/apache/mahout/text/TestSequenceFilesFromDirectory.java
    mahout/trunk/integration/src/test/java/org/apache/mahout/utils/SplitInputTest.java
    mahout/trunk/integration/src/test/java/org/apache/mahout/utils/vectors/csv/CSVVectorIteratorTest.java
    mahout/trunk/integration/src/test/java/org/apache/mahout/utils/vectors/io/VectorWriterTest.java
    mahout/trunk/integration/src/test/java/org/apache/mahout/utils/vectors/lucene/CachedTermInfoTest.java
    mahout/trunk/integration/src/test/java/org/apache/mahout/utils/vectors/lucene/LuceneIterableTest.java

Modified: mahout/trunk/CHANGELOG
URL: http://svn.apache.org/viewvc/mahout/trunk/CHANGELOG?rev=1491265&r1=1491264&r2=1491265&view=diff
==============================================================================
--- mahout/trunk/CHANGELOG (original)
+++ mahout/trunk/CHANGELOG Sun Jun  9 18:50:03 2013
@@ -2,6 +2,10 @@ Mahout Change Log
 
 Release 0.8 - unreleased
 
+  MAHOUT-1211: Disabled swallowing of IOExceptions is Closeables.close for writers (dfilimon)
+
+  MAHOUT-1164: Make ARFF integration generate meta-data in JSON format (Marty Kube via ssc)
+
   MAHOUT-1164: Make ARFF integration generate meta-data in JSON format (Marty Kube via ssc)
 
   MAHOUT-1163: Make random forest classifier meta-data file human readable (Marty Kube via ssc)
@@ -104,4 +108,4 @@ Release 0.8 - unreleased
 
   MAHOUT-1126: Filter out bad META-INF files in job packaging (Pat Ferrel, gsingers)
 
-  MAHOUT-1211: Change deprecated Closeables.closeQuietly calls (smarthi, gsingers, srowen, dlyubimov)
\ No newline at end of file
+  MAHOUT-1211: Change deprecated Closeables.closeQuietly calls (smarthi, gsingers, srowen, dlyubimov)

Modified: mahout/trunk/core/src/main/java/org/apache/mahout/cf/taste/hadoop/als/FactorizationEvaluator.java
URL: http://svn.apache.org/viewvc/mahout/trunk/core/src/main/java/org/apache/mahout/cf/taste/hadoop/als/FactorizationEvaluator.java?rev=1491265&r1=1491264&r2=1491265&view=diff
==============================================================================
--- mahout/trunk/core/src/main/java/org/apache/mahout/cf/taste/hadoop/als/FactorizationEvaluator.java (original)
+++ mahout/trunk/core/src/main/java/org/apache/mahout/cf/taste/hadoop/als/FactorizationEvaluator.java Sun Jun  9 18:50:03 2013
@@ -17,6 +17,12 @@
 
 package org.apache.mahout.cf.taste.hadoop.als;
 
+import java.io.BufferedWriter;
+import java.io.IOException;
+import java.io.OutputStreamWriter;
+import java.util.List;
+import java.util.Map;
+
 import com.google.common.base.Charsets;
 import com.google.common.io.Closeables;
 import org.apache.hadoop.conf.Configuration;
@@ -43,12 +49,6 @@ import org.apache.mahout.common.iterator
 import org.apache.mahout.math.Vector;
 import org.apache.mahout.math.map.OpenIntObjectHashMap;
 
-import java.io.BufferedWriter;
-import java.io.IOException;
-import java.io.OutputStreamWriter;
-import java.util.List;
-import java.util.Map;
-
 /**
  * <p>Measures the root-mean-squared error of a ratring matrix factorization against a test set.</p>
  *
@@ -112,7 +112,7 @@ public class FactorizationEvaluator exte
       writer = new BufferedWriter(new OutputStreamWriter(outputStream, Charsets.UTF_8));
       writer.write(String.valueOf(rmse));
     } finally {
-      Closeables.close(writer, true);
+      Closeables.close(writer, false);
     }
 
     return 0;

Modified: mahout/trunk/core/src/main/java/org/apache/mahout/cf/taste/hadoop/als/ParallelALSFactorizationJob.java
URL: http://svn.apache.org/viewvc/mahout/trunk/core/src/main/java/org/apache/mahout/cf/taste/hadoop/als/ParallelALSFactorizationJob.java?rev=1491265&r1=1491264&r2=1491265&view=diff
==============================================================================
--- mahout/trunk/core/src/main/java/org/apache/mahout/cf/taste/hadoop/als/ParallelALSFactorizationJob.java (original)
+++ mahout/trunk/core/src/main/java/org/apache/mahout/cf/taste/hadoop/als/ParallelALSFactorizationJob.java Sun Jun  9 18:50:03 2013
@@ -17,6 +17,11 @@
 
 package org.apache.mahout.cf.taste.hadoop.als;
 
+import java.io.IOException;
+import java.util.List;
+import java.util.Map;
+import java.util.Random;
+
 import com.google.common.base.Preconditions;
 import com.google.common.io.Closeables;
 import org.apache.hadoop.conf.Configuration;
@@ -56,11 +61,6 @@ import org.apache.mahout.math.VectorWrit
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-import java.io.IOException;
-import java.util.List;
-import java.util.Map;
-import java.util.Random;
-
 /**
  * <p>MapReduce implementation of the two factorization algorithms described in
  *
@@ -239,7 +239,7 @@ public class ParallelALSFactorizationJob
         writer.append(index, featureVector);
       }
     } finally {
-      Closeables.close(writer, true);
+      Closeables.close(writer, false);
     }
   }
 

Modified: mahout/trunk/core/src/main/java/org/apache/mahout/cf/taste/impl/recommender/svd/FilePersistenceStrategy.java
URL: http://svn.apache.org/viewvc/mahout/trunk/core/src/main/java/org/apache/mahout/cf/taste/impl/recommender/svd/FilePersistenceStrategy.java?rev=1491265&r1=1491264&r2=1491265&view=diff
==============================================================================
--- mahout/trunk/core/src/main/java/org/apache/mahout/cf/taste/impl/recommender/svd/FilePersistenceStrategy.java (original)
+++ mahout/trunk/core/src/main/java/org/apache/mahout/cf/taste/impl/recommender/svd/FilePersistenceStrategy.java Sun Jun  9 18:50:03 2013
@@ -17,14 +17,6 @@
 
 package org.apache.mahout.cf.taste.impl.recommender.svd;
 
-import com.google.common.base.Preconditions;
-import com.google.common.io.Closeables;
-import org.apache.mahout.cf.taste.common.NoSuchItemException;
-import org.apache.mahout.cf.taste.common.NoSuchUserException;
-import org.apache.mahout.cf.taste.impl.common.FastByIDMap;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
 import java.io.BufferedInputStream;
 import java.io.BufferedOutputStream;
 import java.io.DataInput;
@@ -37,6 +29,14 @@ import java.io.FileOutputStream;
 import java.io.IOException;
 import java.util.Map;
 
+import com.google.common.base.Preconditions;
+import com.google.common.io.Closeables;
+import org.apache.mahout.cf.taste.common.NoSuchItemException;
+import org.apache.mahout.cf.taste.common.NoSuchUserException;
+import org.apache.mahout.cf.taste.impl.common.FastByIDMap;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
 /** Provides a file-based persistent store. */
 public class FilePersistenceStrategy implements PersistenceStrategy {
 
@@ -75,7 +75,7 @@ public class FilePersistenceStrategy imp
       out = new DataOutputStream(new BufferedOutputStream(new FileOutputStream(file)));
       writeBinary(factorization, out);
     } finally {
-      Closeables.close(out, true);
+      Closeables.close(out, false);
     }
   }
 

Modified: mahout/trunk/core/src/main/java/org/apache/mahout/cf/taste/impl/similarity/precompute/FileSimilarItemsWriter.java
URL: http://svn.apache.org/viewvc/mahout/trunk/core/src/main/java/org/apache/mahout/cf/taste/impl/similarity/precompute/FileSimilarItemsWriter.java?rev=1491265&r1=1491264&r2=1491265&view=diff
==============================================================================
--- mahout/trunk/core/src/main/java/org/apache/mahout/cf/taste/impl/similarity/precompute/FileSimilarItemsWriter.java (original)
+++ mahout/trunk/core/src/main/java/org/apache/mahout/cf/taste/impl/similarity/precompute/FileSimilarItemsWriter.java Sun Jun  9 18:50:03 2013
@@ -17,18 +17,18 @@
 
 package org.apache.mahout.cf.taste.impl.similarity.precompute;
 
-import com.google.common.base.Charsets;
-import com.google.common.io.Closeables;
-import org.apache.mahout.cf.taste.similarity.precompute.SimilarItem;
-import org.apache.mahout.cf.taste.similarity.precompute.SimilarItems;
-import org.apache.mahout.cf.taste.similarity.precompute.SimilarItemsWriter;
-
 import java.io.BufferedWriter;
 import java.io.File;
 import java.io.FileOutputStream;
 import java.io.IOException;
 import java.io.OutputStreamWriter;
 
+import com.google.common.base.Charsets;
+import com.google.common.io.Closeables;
+import org.apache.mahout.cf.taste.similarity.precompute.SimilarItem;
+import org.apache.mahout.cf.taste.similarity.precompute.SimilarItems;
+import org.apache.mahout.cf.taste.similarity.precompute.SimilarItemsWriter;
+
 /**
  * Persist the precomputed item similarities to a file that can later be used
  * by a {@link org.apache.mahout.cf.taste.impl.similarity.file.FileItemSimilarity}
@@ -62,6 +62,6 @@ public class FileSimilarItemsWriter impl
 
   @Override
   public void close() throws IOException {
-    Closeables.close(writer, true);
+    Closeables.close(writer, false);
   }
 }

Modified: mahout/trunk/core/src/main/java/org/apache/mahout/cf/taste/impl/similarity/precompute/MultithreadedBatchItemSimilarities.java
URL: http://svn.apache.org/viewvc/mahout/trunk/core/src/main/java/org/apache/mahout/cf/taste/impl/similarity/precompute/MultithreadedBatchItemSimilarities.java?rev=1491265&r1=1491264&r2=1491265&view=diff
==============================================================================
--- mahout/trunk/core/src/main/java/org/apache/mahout/cf/taste/impl/similarity/precompute/MultithreadedBatchItemSimilarities.java (original)
+++ mahout/trunk/core/src/main/java/org/apache/mahout/cf/taste/impl/similarity/precompute/MultithreadedBatchItemSimilarities.java Sun Jun  9 18:50:03 2013
@@ -17,6 +17,15 @@
 
 package org.apache.mahout.cf.taste.impl.similarity.precompute;
 
+import java.io.IOException;
+import java.util.List;
+import java.util.concurrent.BlockingQueue;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+import java.util.concurrent.LinkedBlockingQueue;
+import java.util.concurrent.TimeUnit;
+import java.util.concurrent.atomic.AtomicInteger;
+
 import com.google.common.collect.Lists;
 import com.google.common.io.Closeables;
 import org.apache.mahout.cf.taste.common.TasteException;
@@ -30,15 +39,6 @@ import org.apache.mahout.cf.taste.simila
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-import java.io.IOException;
-import java.util.List;
-import java.util.concurrent.BlockingQueue;
-import java.util.concurrent.ExecutorService;
-import java.util.concurrent.Executors;
-import java.util.concurrent.LinkedBlockingQueue;
-import java.util.concurrent.TimeUnit;
-import java.util.concurrent.atomic.AtomicInteger;
-
 /**
  * Precompute item similarities in parallel on a single machine. The recommender given to this class must use a
  * DataModel that holds the interactions in memory (such as
@@ -106,7 +106,7 @@ public class MultithreadedBatchItemSimil
       } catch (InterruptedException e) {
         throw new RuntimeException(e);
       }
-      Closeables.close(writer, true);
+      Closeables.close(writer, false);
     }
 
     return output.getNumSimilaritiesProcessed();

Modified: mahout/trunk/core/src/main/java/org/apache/mahout/classifier/df/DFUtils.java
URL: http://svn.apache.org/viewvc/mahout/trunk/core/src/main/java/org/apache/mahout/classifier/df/DFUtils.java?rev=1491265&r1=1491264&r2=1491265&view=diff
==============================================================================
--- mahout/trunk/core/src/main/java/org/apache/mahout/classifier/df/DFUtils.java (original)
+++ mahout/trunk/core/src/main/java/org/apache/mahout/classifier/df/DFUtils.java Sun Jun  9 18:50:03 2013
@@ -17,6 +17,13 @@
 
 package org.apache.mahout.classifier.df;
 
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.DataOutputStream;
+import java.io.IOException;
+import java.nio.charset.Charset;
+import java.util.List;
+
 import com.google.common.collect.Lists;
 import com.google.common.io.Closeables;
 import org.apache.hadoop.conf.Configuration;
@@ -28,13 +35,6 @@ import org.apache.hadoop.io.Writable;
 import org.apache.mahout.classifier.df.node.Node;
 import org.apache.mahout.common.iterator.sequencefile.PathFilters;
 
-import java.io.DataInput;
-import java.io.DataOutput;
-import java.io.DataOutputStream;
-import java.io.IOException;
-import java.nio.charset.Charset;
-import java.util.List;
-
 /**
  * Utility class that contains various helper methods
  */
@@ -157,7 +157,7 @@ public final class DFUtils {
     try {
       writable.write(out);
     } finally {
-      Closeables.close(out, true);
+      Closeables.close(out, false);
     }
   }
   

Modified: mahout/trunk/core/src/main/java/org/apache/mahout/classifier/df/mapreduce/Classifier.java
URL: http://svn.apache.org/viewvc/mahout/trunk/core/src/main/java/org/apache/mahout/classifier/df/mapreduce/Classifier.java?rev=1491265&r1=1491264&r2=1491265&view=diff
==============================================================================
--- mahout/trunk/core/src/main/java/org/apache/mahout/classifier/df/mapreduce/Classifier.java (original)
+++ mahout/trunk/core/src/main/java/org/apache/mahout/classifier/df/mapreduce/Classifier.java Sun Jun  9 18:50:03 2013
@@ -17,6 +17,10 @@
 
 package org.apache.mahout.classifier.df.mapreduce;
 
+import java.io.IOException;
+import java.util.List;
+import java.util.Random;
+
 import com.google.common.collect.Lists;
 import com.google.common.io.Closeables;
 import org.apache.hadoop.conf.Configuration;
@@ -47,11 +51,6 @@ import org.apache.mahout.common.iterator
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-import java.io.IOException;
-import java.net.URI;
-import java.util.List;
-import java.util.Random;
-
 /**
  * Mapreduce implementation that classifies the Input data using a previousely built decision forest
  */
@@ -164,7 +163,7 @@ public class Classifier {
           }
         }
       } finally {
-        Closeables.close(ofile, true);
+        Closeables.close(ofile, false);
       }
     }
     results = new double[resList.size()][2];

Modified: mahout/trunk/core/src/main/java/org/apache/mahout/classifier/df/tools/UDistrib.java
URL: http://svn.apache.org/viewvc/mahout/trunk/core/src/main/java/org/apache/mahout/classifier/df/tools/UDistrib.java?rev=1491265&r1=1491264&r2=1491265&view=diff
==============================================================================
--- mahout/trunk/core/src/main/java/org/apache/mahout/classifier/df/tools/UDistrib.java (original)
+++ mahout/trunk/core/src/main/java/org/apache/mahout/classifier/df/tools/UDistrib.java Sun Jun  9 18:50:03 2013
@@ -17,6 +17,12 @@
 
 package org.apache.mahout.classifier.df.tools;
 
+import java.io.File;
+import java.io.IOException;
+import java.util.Locale;
+import java.util.Random;
+import java.util.Scanner;
+
 import com.google.common.base.Preconditions;
 import com.google.common.io.Closeables;
 import org.apache.commons.cli2.CommandLine;
@@ -41,12 +47,6 @@ import org.apache.mahout.common.RandomUt
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-import java.io.File;
-import java.io.IOException;
-import java.util.Locale;
-import java.util.Random;
-import java.util.Scanner;
-
 /**
  * This tool is used to uniformly distribute the class of all the tuples of the dataset over a given number of
  * partitions.<br>
@@ -188,7 +188,7 @@ public final class UDistrib {
     // close all the files.
     scanner.close();
     for (FSDataOutputStream file : files) {
-      Closeables.close(file, true);
+      Closeables.close(file, false);
     }
     
     // merge all output files

Modified: mahout/trunk/core/src/main/java/org/apache/mahout/classifier/naivebayes/BayesUtils.java
URL: http://svn.apache.org/viewvc/mahout/trunk/core/src/main/java/org/apache/mahout/classifier/naivebayes/BayesUtils.java?rev=1491265&r1=1491264&r2=1491265&view=diff
==============================================================================
--- mahout/trunk/core/src/main/java/org/apache/mahout/classifier/naivebayes/BayesUtils.java (original)
+++ mahout/trunk/core/src/main/java/org/apache/mahout/classifier/naivebayes/BayesUtils.java Sun Jun  9 18:50:03 2013
@@ -107,7 +107,7 @@ public final class BayesUtils {
         writer.append(new Text(label), new IntWritable(i++));
       }
     } finally {
-      Closeables.close(writer, true);
+      Closeables.close(writer, false);
     }
     return i;
   }
@@ -127,7 +127,7 @@ public final class BayesUtils {
         }
       }
     } finally {
-      Closeables.close(writer, true);
+      Closeables.close(writer, false);
     }
     return i;
   }

Modified: mahout/trunk/core/src/main/java/org/apache/mahout/classifier/naivebayes/NaiveBayesModel.java
URL: http://svn.apache.org/viewvc/mahout/trunk/core/src/main/java/org/apache/mahout/classifier/naivebayes/NaiveBayesModel.java?rev=1491265&r1=1491264&r2=1491265&view=diff
==============================================================================
--- mahout/trunk/core/src/main/java/org/apache/mahout/classifier/naivebayes/NaiveBayesModel.java (original)
+++ mahout/trunk/core/src/main/java/org/apache/mahout/classifier/naivebayes/NaiveBayesModel.java Sun Jun  9 18:50:03 2013
@@ -137,7 +137,7 @@ public class NaiveBayesModel {
         VectorWritable.writeVector(out, weightsPerLabelAndFeature.viewRow(row));
       }
     } finally {
-      Closeables.close(out, true);
+      Closeables.close(out, false);
     }
   }
   

Modified: mahout/trunk/core/src/main/java/org/apache/mahout/classifier/sequencelearning/hmm/BaumWelchTrainer.java
URL: http://svn.apache.org/viewvc/mahout/trunk/core/src/main/java/org/apache/mahout/classifier/sequencelearning/hmm/BaumWelchTrainer.java?rev=1491265&r1=1491264&r2=1491265&view=diff
==============================================================================
--- mahout/trunk/core/src/main/java/org/apache/mahout/classifier/sequencelearning/hmm/BaumWelchTrainer.java (original)
+++ mahout/trunk/core/src/main/java/org/apache/mahout/classifier/sequencelearning/hmm/BaumWelchTrainer.java Sun Jun  9 18:50:03 2013
@@ -17,6 +17,14 @@
 
 package org.apache.mahout.classifier.sequencelearning.hmm;
 
+import java.io.DataOutputStream;
+import java.io.FileInputStream;
+import java.io.FileOutputStream;
+import java.io.IOException;
+import java.util.Date;
+import java.util.List;
+import java.util.Scanner;
+
 import com.google.common.collect.Lists;
 import com.google.common.io.Closeables;
 import org.apache.commons.cli2.CommandLine;
@@ -30,14 +38,6 @@ import org.apache.commons.cli2.commandli
 import org.apache.mahout.common.CommandLineUtil;
 import org.apache.mahout.common.commandline.DefaultOptionCreator;
 
-import java.io.DataOutputStream;
-import java.io.FileInputStream;
-import java.io.FileOutputStream;
-import java.io.IOException;
-import java.util.Date;
-import java.util.List;
-import java.util.Scanner;
-
 /**
  * A class for EM training of HMM from console
  */
@@ -121,7 +121,7 @@ public final class BaumWelchTrainer {
       try {
         LossyHmmSerializer.serialize(trainedModel, stream);
       } finally {
-        Closeables.close(stream, true);
+        Closeables.close(stream, false);
       }
 
       //printing tranied model

Modified: mahout/trunk/core/src/main/java/org/apache/mahout/classifier/sequencelearning/hmm/RandomSequenceGenerator.java
URL: http://svn.apache.org/viewvc/mahout/trunk/core/src/main/java/org/apache/mahout/classifier/sequencelearning/hmm/RandomSequenceGenerator.java?rev=1491265&r1=1491264&r2=1491265&view=diff
==============================================================================
--- mahout/trunk/core/src/main/java/org/apache/mahout/classifier/sequencelearning/hmm/RandomSequenceGenerator.java (original)
+++ mahout/trunk/core/src/main/java/org/apache/mahout/classifier/sequencelearning/hmm/RandomSequenceGenerator.java Sun Jun  9 18:50:03 2013
@@ -18,6 +18,13 @@
 
 package org.apache.mahout.classifier.sequencelearning.hmm;
 
+import java.io.DataInputStream;
+import java.io.FileInputStream;
+import java.io.FileOutputStream;
+import java.io.IOException;
+import java.io.OutputStreamWriter;
+import java.io.PrintWriter;
+
 import com.google.common.base.Charsets;
 import com.google.common.io.Closeables;
 import org.apache.commons.cli2.CommandLine;
@@ -30,13 +37,6 @@ import org.apache.commons.cli2.builder.G
 import org.apache.commons.cli2.commandline.Parser;
 import org.apache.mahout.common.CommandLineUtil;
 
-import java.io.DataInputStream;
-import java.io.FileInputStream;
-import java.io.FileOutputStream;
-import java.io.IOException;
-import java.io.OutputStreamWriter;
-import java.io.PrintWriter;
-
 /**
  * Command-line tool for generating random sequences by given HMM
  */
@@ -99,7 +99,7 @@ public final class RandomSequenceGenerat
           writer.print(' ');
         }
       } finally {
-        Closeables.close(writer, true);
+        Closeables.close(writer, false);
       }
     } catch (OptionException e) {
       CommandLineUtil.printHelp(optionGroup);

Modified: mahout/trunk/core/src/main/java/org/apache/mahout/classifier/sequencelearning/hmm/ViterbiEvaluator.java
URL: http://svn.apache.org/viewvc/mahout/trunk/core/src/main/java/org/apache/mahout/classifier/sequencelearning/hmm/ViterbiEvaluator.java?rev=1491265&r1=1491264&r2=1491265&view=diff
==============================================================================
--- mahout/trunk/core/src/main/java/org/apache/mahout/classifier/sequencelearning/hmm/ViterbiEvaluator.java (original)
+++ mahout/trunk/core/src/main/java/org/apache/mahout/classifier/sequencelearning/hmm/ViterbiEvaluator.java Sun Jun  9 18:50:03 2013
@@ -17,6 +17,15 @@
 
 package org.apache.mahout.classifier.sequencelearning.hmm;
 
+import java.io.DataInputStream;
+import java.io.FileInputStream;
+import java.io.FileOutputStream;
+import java.io.IOException;
+import java.io.OutputStreamWriter;
+import java.io.PrintWriter;
+import java.util.List;
+import java.util.Scanner;
+
 import com.google.common.base.Charsets;
 import com.google.common.collect.Lists;
 import com.google.common.io.Closeables;
@@ -31,15 +40,6 @@ import org.apache.commons.cli2.commandli
 import org.apache.mahout.common.CommandLineUtil;
 import org.apache.mahout.common.commandline.DefaultOptionCreator;
 
-import java.io.DataInputStream;
-import java.io.FileInputStream;
-import java.io.FileOutputStream;
-import java.io.IOException;
-import java.io.OutputStreamWriter;
-import java.io.PrintWriter;
-import java.util.List;
-import java.util.Scanner;
-
 /**
  * Command-line tool for Viterbi evaluating
  */
@@ -117,7 +117,7 @@ public final class ViterbiEvaluator {
           writer.print(' ');
         }
       } finally {
-        Closeables.close(writer, true);
+        Closeables.close(writer, false);
       }
 
       if (computeLikelihood) {

Modified: mahout/trunk/core/src/main/java/org/apache/mahout/classifier/sgd/ModelSerializer.java
URL: http://svn.apache.org/viewvc/mahout/trunk/core/src/main/java/org/apache/mahout/classifier/sgd/ModelSerializer.java?rev=1491265&r1=1491264&r2=1491265&view=diff
==============================================================================
--- mahout/trunk/core/src/main/java/org/apache/mahout/classifier/sgd/ModelSerializer.java (original)
+++ mahout/trunk/core/src/main/java/org/apache/mahout/classifier/sgd/ModelSerializer.java Sun Jun  9 18:50:03 2013
@@ -17,9 +17,6 @@
 
 package org.apache.mahout.classifier.sgd;
 
-import com.google.common.io.Closeables;
-import org.apache.hadoop.io.Writable;
-
 import java.io.DataInput;
 import java.io.DataInputStream;
 import java.io.DataOutputStream;
@@ -27,6 +24,9 @@ import java.io.FileOutputStream;
 import java.io.IOException;
 import java.io.InputStream;
 
+import com.google.common.io.Closeables;
+import org.apache.hadoop.io.Writable;
+
 /**
  * Provides the ability to store SGD model-related objects as binary files.
  */
@@ -41,7 +41,7 @@ public final class ModelSerializer {
     try {
       PolymorphicWritable.write(out, model);
     } finally {
-      Closeables.close(out, true);
+      Closeables.close(out, false);
     }
   }
 
@@ -50,7 +50,7 @@ public final class ModelSerializer {
     try {
       PolymorphicWritable.write(out, model);
     } finally {
-      Closeables.close(out, true);
+      Closeables.close(out, false);
     }
   }
 
@@ -59,7 +59,7 @@ public final class ModelSerializer {
     try {
       PolymorphicWritable.write(out, model);
     } finally {
-      Closeables.close(out, true);
+      Closeables.close(out, false);
     }
   }
 
@@ -68,7 +68,7 @@ public final class ModelSerializer {
     try {
       return PolymorphicWritable.read(dataIn, clazz);
     } finally {
-      Closeables.close(in, true);
+      Closeables.close(in, false);
     }
   }
 

Modified: mahout/trunk/core/src/main/java/org/apache/mahout/clustering/canopy/CanopyDriver.java
URL: http://svn.apache.org/viewvc/mahout/trunk/core/src/main/java/org/apache/mahout/clustering/canopy/CanopyDriver.java?rev=1491265&r1=1491264&r2=1491265&view=diff
==============================================================================
--- mahout/trunk/core/src/main/java/org/apache/mahout/clustering/canopy/CanopyDriver.java (original)
+++ mahout/trunk/core/src/main/java/org/apache/mahout/clustering/canopy/CanopyDriver.java Sun Jun  9 18:50:03 2013
@@ -300,7 +300,7 @@ public class CanopyDriver extends Abstra
         }
       }
     } finally {
-      Closeables.close(writer, true);
+      Closeables.close(writer, false);
     }
     return canopyOutputDir;
   }

Modified: mahout/trunk/core/src/main/java/org/apache/mahout/clustering/classify/ClusterClassifier.java
URL: http://svn.apache.org/viewvc/mahout/trunk/core/src/main/java/org/apache/mahout/clustering/classify/ClusterClassifier.java?rev=1491265&r1=1491264&r2=1491265&view=diff
==============================================================================
--- mahout/trunk/core/src/main/java/org/apache/mahout/clustering/classify/ClusterClassifier.java (original)
+++ mahout/trunk/core/src/main/java/org/apache/mahout/clustering/classify/ClusterClassifier.java Sun Jun  9 18:50:03 2013
@@ -197,7 +197,7 @@ public class ClusterClassifier extends A
         Writable key = new IntWritable(i);
         writer.append(key, cw);
       } finally {
-        Closeables.close(writer, true);
+        Closeables.close(writer, false);
       }
     }
   }

Modified: mahout/trunk/core/src/main/java/org/apache/mahout/clustering/kmeans/RandomSeedGenerator.java
URL: http://svn.apache.org/viewvc/mahout/trunk/core/src/main/java/org/apache/mahout/clustering/kmeans/RandomSeedGenerator.java?rev=1491265&r1=1491264&r2=1491265&view=diff
==============================================================================
--- mahout/trunk/core/src/main/java/org/apache/mahout/clustering/kmeans/RandomSeedGenerator.java (original)
+++ mahout/trunk/core/src/main/java/org/apache/mahout/clustering/kmeans/RandomSeedGenerator.java Sun Jun  9 18:50:03 2013
@@ -123,7 +123,7 @@ public final class RandomSeedGenerator {
         }
         log.info("Wrote {} Klusters to {}", k, outFile);
       } finally {
-        Closeables.close(writer, true);
+        Closeables.close(writer, false);
       }
     }
     

Modified: mahout/trunk/core/src/main/java/org/apache/mahout/clustering/meanshift/MeanShiftCanopyDriver.java
URL: http://svn.apache.org/viewvc/mahout/trunk/core/src/main/java/org/apache/mahout/clustering/meanshift/MeanShiftCanopyDriver.java?rev=1491265&r1=1491264&r2=1491265&view=diff
==============================================================================
--- mahout/trunk/core/src/main/java/org/apache/mahout/clustering/meanshift/MeanShiftCanopyDriver.java (original)
+++ mahout/trunk/core/src/main/java/org/apache/mahout/clustering/meanshift/MeanShiftCanopyDriver.java Sun Jun  9 18:50:03 2013
@@ -218,7 +218,7 @@ public class MeanShiftCanopyDriver exten
           writer.append(new Text(), clusterWritable);
         }
       } finally {
-        Closeables.close(writer, true);
+        Closeables.close(writer, false);
       }
     }
   }
@@ -332,7 +332,7 @@ public class MeanShiftCanopyDriver exten
           writer.append(new Text(cluster.getIdentifier()), clusterWritable);
         }
       } finally {
-        Closeables.close(writer, true);
+        Closeables.close(writer, false);
       }
       clustersIn = clustersOut;
       iteration++;
@@ -493,7 +493,7 @@ public class MeanShiftCanopyDriver exten
           writer.append(new IntWritable(closest.getId()), new WeightedVectorWritable(1, canopy.getCenter()));
         }
       } finally {
-        Closeables.close(writer, true);
+        Closeables.close(writer, false);
       }
     }
   }

Modified: mahout/trunk/core/src/main/java/org/apache/mahout/clustering/spectral/common/VectorCache.java
URL: http://svn.apache.org/viewvc/mahout/trunk/core/src/main/java/org/apache/mahout/clustering/spectral/common/VectorCache.java?rev=1491265&r1=1491264&r2=1491265&view=diff
==============================================================================
--- mahout/trunk/core/src/main/java/org/apache/mahout/clustering/spectral/common/VectorCache.java (original)
+++ mahout/trunk/core/src/main/java/org/apache/mahout/clustering/spectral/common/VectorCache.java Sun Jun  9 18:50:03 2013
@@ -17,6 +17,10 @@
 
 package org.apache.mahout.clustering.spectral.common;
 
+import java.io.IOException;
+import java.net.URI;
+import java.util.Arrays;
+
 import com.google.common.io.Closeables;
 import org.apache.hadoop.conf.Configuration;
 import org.apache.hadoop.filecache.DistributedCache;
@@ -33,10 +37,6 @@ import org.apache.mahout.math.VectorWrit
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-import java.io.IOException;
-import java.net.URI;
-import java.util.Arrays;
-
 
 /**
  * This class handles reading and writing vectors to the Hadoop
@@ -76,7 +76,7 @@ public final class VectorCache {
     try {
       writer.append(key, new VectorWritable(vector));
     } finally {
-      Closeables.close(writer, true);
+      Closeables.close(writer, false);
     }
 
     if (deleteOnExit) {

Modified: mahout/trunk/core/src/main/java/org/apache/mahout/clustering/streaming/mapreduce/StreamingKMeansUtilsMR.java
URL: http://svn.apache.org/viewvc/mahout/trunk/core/src/main/java/org/apache/mahout/clustering/streaming/mapreduce/StreamingKMeansUtilsMR.java?rev=1491265&r1=1491264&r2=1491265&view=diff
==============================================================================
--- mahout/trunk/core/src/main/java/org/apache/mahout/clustering/streaming/mapreduce/StreamingKMeansUtilsMR.java (original)
+++ mahout/trunk/core/src/main/java/org/apache/mahout/clustering/streaming/mapreduce/StreamingKMeansUtilsMR.java Sun Jun  9 18:50:03 2013
@@ -126,7 +126,7 @@ public final class StreamingKMeansUtilsM
         writer.append(new IntWritable(i++), new CentroidWritable(centroid));
       }
     } finally {
-      Closeables.close(writer, true);
+      Closeables.close(writer, false);
     }
   }
 
@@ -141,7 +141,7 @@ public final class StreamingKMeansUtilsM
         writer.append(new IntWritable(i++), new VectorWritable(vector));
       }
     } finally {
-      Closeables.close(writer, true);
+      Closeables.close(writer, false);
     }
   }
 }

Modified: mahout/trunk/core/src/main/java/org/apache/mahout/common/HadoopUtil.java
URL: http://svn.apache.org/viewvc/mahout/trunk/core/src/main/java/org/apache/mahout/common/HadoopUtil.java?rev=1491265&r1=1491264&r2=1491265&view=diff
==============================================================================
--- mahout/trunk/core/src/main/java/org/apache/mahout/common/HadoopUtil.java (original)
+++ mahout/trunk/core/src/main/java/org/apache/mahout/common/HadoopUtil.java Sun Jun  9 18:50:03 2013
@@ -288,7 +288,7 @@ public final class HadoopUtil {
     try {
       out.writeInt(value);
     } finally {
-      Closeables.close(out, true);
+      Closeables.close(out, false);
     }
   }
 

Modified: mahout/trunk/core/src/main/java/org/apache/mahout/fpm/pfpgrowth/FPGrowthDriver.java
URL: http://svn.apache.org/viewvc/mahout/trunk/core/src/main/java/org/apache/mahout/fpm/pfpgrowth/FPGrowthDriver.java?rev=1491265&r1=1491264&r2=1491265&view=diff
==============================================================================
--- mahout/trunk/core/src/main/java/org/apache/mahout/fpm/pfpgrowth/FPGrowthDriver.java (original)
+++ mahout/trunk/core/src/main/java/org/apache/mahout/fpm/pfpgrowth/FPGrowthDriver.java Sun Jun  9 18:50:03 2013
@@ -17,6 +17,11 @@
 
 package org.apache.mahout.fpm.pfpgrowth;
 
+import java.io.IOException;
+import java.nio.charset.Charset;
+import java.util.Collection;
+import java.util.List;
+
 import com.google.common.collect.Sets;
 import com.google.common.io.Closeables;
 import org.apache.hadoop.conf.Configuration;
@@ -40,11 +45,6 @@ import org.apache.mahout.fpm.pfpgrowth.f
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-import java.io.IOException;
-import java.nio.charset.Charset;
-import java.util.Collection;
-import java.util.List;
-
 public final class FPGrowthDriver extends AbstractJob {
 
   private static final Logger log = LoggerFactory.getLogger(FPGrowthDriver.class);
@@ -179,7 +179,7 @@ public final class FPGrowthDriver extend
                 new StringOutputConverter(new SequenceFileOutputCollector<Text, TopKStringPatterns>(writer)),
                 new ContextStatusUpdater(null));
       } finally {
-        Closeables.close(writer, true);
+        Closeables.close(writer, false);
         Closeables.close(inputStream, true);
         Closeables.close(inputStreamAgain, true);
       }
@@ -201,7 +201,7 @@ public final class FPGrowthDriver extend
                 new StringOutputConverter(new SequenceFileOutputCollector<Text, TopKStringPatterns>(writer)),
                 new ContextStatusUpdater(null));
       } finally {
-        Closeables.close(writer, true);
+        Closeables.close(writer, false);
         Closeables.close(inputStream, true);
         Closeables.close(inputStreamAgain, true);
       }

Modified: mahout/trunk/core/src/main/java/org/apache/mahout/math/hadoop/decomposer/DistributedLanczosSolver.java
URL: http://svn.apache.org/viewvc/mahout/trunk/core/src/main/java/org/apache/mahout/math/hadoop/decomposer/DistributedLanczosSolver.java?rev=1491265&r1=1491264&r2=1491265&view=diff
==============================================================================
--- mahout/trunk/core/src/main/java/org/apache/mahout/math/hadoop/decomposer/DistributedLanczosSolver.java (original)
+++ mahout/trunk/core/src/main/java/org/apache/mahout/math/hadoop/decomposer/DistributedLanczosSolver.java Sun Jun  9 18:50:03 2013
@@ -17,6 +17,10 @@
 
 package org.apache.mahout.math.hadoop.decomposer;
 
+import java.io.IOException;
+import java.util.List;
+import java.util.Map;
+
 import com.google.common.io.Closeables;
 import org.apache.hadoop.conf.Configurable;
 import org.apache.hadoop.conf.Configuration;
@@ -39,10 +43,6 @@ import org.apache.mahout.math.hadoop.Dis
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-import java.io.IOException;
-import java.util.List;
-import java.util.Map;
-
 /**
  * See the SSVD code for a better option than using this:
  *
@@ -233,7 +233,7 @@ public class DistributedLanczosSolver ex
         seqWriter.append(iw, vw);
       }
     } finally {
-      Closeables.close(seqWriter, true);
+      Closeables.close(seqWriter, false);
     }
   }
 

Modified: mahout/trunk/core/src/main/java/org/apache/mahout/math/hadoop/decomposer/EigenVerificationJob.java
URL: http://svn.apache.org/viewvc/mahout/trunk/core/src/main/java/org/apache/mahout/math/hadoop/decomposer/EigenVerificationJob.java?rev=1491265&r1=1491264&r2=1491265&view=diff
==============================================================================
--- mahout/trunk/core/src/main/java/org/apache/mahout/math/hadoop/decomposer/EigenVerificationJob.java (original)
+++ mahout/trunk/core/src/main/java/org/apache/mahout/math/hadoop/decomposer/EigenVerificationJob.java Sun Jun  9 18:50:03 2013
@@ -17,6 +17,13 @@
 
 package org.apache.mahout.math.hadoop.decomposer;
 
+import java.io.IOException;
+import java.util.Collection;
+import java.util.Collections;
+import java.util.Comparator;
+import java.util.List;
+import java.util.Map;
+
 import com.google.common.collect.Lists;
 import com.google.common.collect.Maps;
 import com.google.common.io.Closeables;
@@ -41,13 +48,6 @@ import org.apache.mahout.math.hadoop.Dis
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-import java.io.IOException;
-import java.util.Collection;
-import java.util.Collections;
-import java.util.Comparator;
-import java.util.List;
-import java.util.Map;
-
 /**
  * <p>Class for taking the output of an eigendecomposition (specified as a Path location), and verifies correctness,
  * in terms of the following: if you have a vector e, and a matrix m, then let e' = m.timesSquared(v); the error
@@ -211,7 +211,7 @@ public class EigenVerificationJob extend
         }
       }
     } finally {
-      Closeables.close(seqWriter, true);
+      Closeables.close(seqWriter, false);
     }
     cleanedEigensPath = path;
   }

Modified: mahout/trunk/core/src/main/java/org/apache/mahout/math/hadoop/decomposer/HdfsBackedLanczosState.java
URL: http://svn.apache.org/viewvc/mahout/trunk/core/src/main/java/org/apache/mahout/math/hadoop/decomposer/HdfsBackedLanczosState.java?rev=1491265&r1=1491264&r2=1491265&view=diff
==============================================================================
--- mahout/trunk/core/src/main/java/org/apache/mahout/math/hadoop/decomposer/HdfsBackedLanczosState.java (original)
+++ mahout/trunk/core/src/main/java/org/apache/mahout/math/hadoop/decomposer/HdfsBackedLanczosState.java Sun Jun  9 18:50:03 2013
@@ -17,6 +17,9 @@
 
 package org.apache.mahout.math.hadoop.decomposer;
 
+import java.io.IOException;
+import java.util.Map;
+
 import com.google.common.io.Closeables;
 import org.apache.hadoop.conf.Configurable;
 import org.apache.hadoop.conf.Configuration;
@@ -34,9 +37,6 @@ import org.apache.mahout.math.decomposer
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-import java.io.IOException;
-import java.util.Map;
-
 public class HdfsBackedLanczosState extends LanczosState implements Configurable {
 
   private static final Logger log = LoggerFactory.getLogger(HdfsBackedLanczosState.class);
@@ -148,7 +148,7 @@ public class HdfsBackedLanczosState exte
           IntWritable.class, VectorWritable.class);
       writer.append(new IntWritable(key), new VectorWritable(vector));
     } finally {
-      Closeables.close(writer, true);
+      Closeables.close(writer, false);
     }
   }
 

Modified: mahout/trunk/core/src/main/java/org/apache/mahout/math/hadoop/similarity/cooccurrence/Vectors.java
URL: http://svn.apache.org/viewvc/mahout/trunk/core/src/main/java/org/apache/mahout/math/hadoop/similarity/cooccurrence/Vectors.java?rev=1491265&r1=1491264&r2=1491265&view=diff
==============================================================================
--- mahout/trunk/core/src/main/java/org/apache/mahout/math/hadoop/similarity/cooccurrence/Vectors.java (original)
+++ mahout/trunk/core/src/main/java/org/apache/mahout/math/hadoop/similarity/cooccurrence/Vectors.java Sun Jun  9 18:50:03 2013
@@ -17,6 +17,10 @@
 
 package org.apache.mahout.math.hadoop.similarity.cooccurrence;
 
+import java.io.DataInput;
+import java.io.IOException;
+import java.util.Iterator;
+
 import com.google.common.base.Preconditions;
 import com.google.common.io.Closeables;
 import org.apache.hadoop.conf.Configuration;
@@ -32,10 +36,6 @@ import org.apache.mahout.math.Vector.Ele
 import org.apache.mahout.math.VectorWritable;
 import org.apache.mahout.math.map.OpenIntIntHashMap;
 
-import java.io.DataInput;
-import java.io.IOException;
-import java.util.Iterator;
-
 public final class Vectors {
 
   private Vectors() {}
@@ -142,7 +142,7 @@ public final class Vectors {
       vectorWritable.setWritesLaxPrecision(laxPrecision);
       vectorWritable.write(out);
     } finally {
-      Closeables.close(out, true);
+      Closeables.close(out, false);
     }
   }
 

Modified: mahout/trunk/core/src/main/java/org/apache/mahout/math/hadoop/stochasticsvd/qr/QRFirstStep.java
URL: http://svn.apache.org/viewvc/mahout/trunk/core/src/main/java/org/apache/mahout/math/hadoop/stochasticsvd/qr/QRFirstStep.java?rev=1491265&r1=1491264&r2=1491265&view=diff
==============================================================================
--- mahout/trunk/core/src/main/java/org/apache/mahout/math/hadoop/stochasticsvd/qr/QRFirstStep.java (original)
+++ mahout/trunk/core/src/main/java/org/apache/mahout/math/hadoop/stochasticsvd/qr/QRFirstStep.java Sun Jun  9 18:50:03 2013
@@ -239,7 +239,7 @@ public class QRFirstStep implements Clos
         flushSolver();
         assert tempQw != null;
         closeables.remove(tempQw);
-        Closeables.close(tempQw, true);
+        Closeables.close(tempQw, false);
       }
       flushQBlocks();
 

Modified: mahout/trunk/core/src/main/java/org/apache/mahout/vectorizer/DictionaryVectorizer.java
URL: http://svn.apache.org/viewvc/mahout/trunk/core/src/main/java/org/apache/mahout/vectorizer/DictionaryVectorizer.java?rev=1491265&r1=1491264&r2=1491265&view=diff
==============================================================================
--- mahout/trunk/core/src/main/java/org/apache/mahout/vectorizer/DictionaryVectorizer.java (original)
+++ mahout/trunk/core/src/main/java/org/apache/mahout/vectorizer/DictionaryVectorizer.java Sun Jun  9 18:50:03 2013
@@ -237,7 +237,7 @@ public final class DictionaryVectorizer 
       for (Pair<Writable,Writable> record
            : new SequenceFileDirIterable<Writable,Writable>(filesPattern, PathType.GLOB, null, null, true, conf)) {
         if (currentChunkSize > chunkSizeLimit) {
-          Closeables.close(dictWriter, true);
+          Closeables.close(dictWriter, false);
           chunkIndex++;
 
           chunkPath = new Path(dictionaryPathBase, DICTIONARY_FILE + chunkIndex);
@@ -254,7 +254,7 @@ public final class DictionaryVectorizer 
       }
       maxTermDimension[0] = i;
     } finally {
-      Closeables.close(dictWriter, true);
+      Closeables.close(dictWriter, false);
     }
     
     return chunkPaths;

Modified: mahout/trunk/core/src/main/java/org/apache/mahout/vectorizer/tfidf/TFIDFConverter.java
URL: http://svn.apache.org/viewvc/mahout/trunk/core/src/main/java/org/apache/mahout/vectorizer/tfidf/TFIDFConverter.java?rev=1491265&r1=1491264&r2=1491265&view=diff
==============================================================================
--- mahout/trunk/core/src/main/java/org/apache/mahout/vectorizer/tfidf/TFIDFConverter.java (original)
+++ mahout/trunk/core/src/main/java/org/apache/mahout/vectorizer/tfidf/TFIDFConverter.java Sun Jun  9 18:50:03 2013
@@ -223,7 +223,7 @@ public final class TFIDFConverter {
                                                                    conf)) {
 
         if (currentChunkSize > chunkSizeLimit) {
-          Closeables.close(freqWriter, true);
+          Closeables.close(freqWriter, false);
           chunkIndex++;
 
           chunkPath = new Path(dictionaryPathBase, FREQUENCY_FILE + chunkIndex);
@@ -249,7 +249,7 @@ public final class TFIDFConverter {
       Long[] counts = {featureCount, vectorCount};
       return new Pair<Long[], List<Path>>(counts, chunkPaths);
     } finally {
-      Closeables.close(freqWriter, true);
+      Closeables.close(freqWriter, false);
     }
   }
 

Modified: mahout/trunk/core/src/test/java/org/apache/mahout/classifier/df/mapreduce/partial/PartialBuilderTest.java
URL: http://svn.apache.org/viewvc/mahout/trunk/core/src/test/java/org/apache/mahout/classifier/df/mapreduce/partial/PartialBuilderTest.java?rev=1491265&r1=1491264&r2=1491265&view=diff
==============================================================================
--- mahout/trunk/core/src/test/java/org/apache/mahout/classifier/df/mapreduce/partial/PartialBuilderTest.java (original)
+++ mahout/trunk/core/src/test/java/org/apache/mahout/classifier/df/mapreduce/partial/PartialBuilderTest.java Sun Jun  9 18:50:03 2013
@@ -74,7 +74,7 @@ public final class PartialBuilderTest ex
         writer.append(keys[index], values[index]);
       }
     } finally {
-      Closeables.close(writer, true);
+      Closeables.close(writer, false);
     }
 
     // load the output and make sure its valid

Modified: mahout/trunk/core/src/test/java/org/apache/mahout/classifier/naivebayes/NaiveBayesTest.java
URL: http://svn.apache.org/viewvc/mahout/trunk/core/src/test/java/org/apache/mahout/classifier/naivebayes/NaiveBayesTest.java?rev=1491265&r1=1491264&r2=1491265&view=diff
==============================================================================
--- mahout/trunk/core/src/test/java/org/apache/mahout/classifier/naivebayes/NaiveBayesTest.java (original)
+++ mahout/trunk/core/src/test/java/org/apache/mahout/classifier/naivebayes/NaiveBayesTest.java Sun Jun  9 18:50:03 2013
@@ -17,6 +17,8 @@
 
 package org.apache.mahout.classifier.naivebayes;
 
+import java.io.File;
+
 import com.google.common.io.Closeables;
 import org.apache.hadoop.conf.Configuration;
 import org.apache.hadoop.fs.FileSystem;
@@ -33,8 +35,6 @@ import org.apache.mahout.math.hadoop.Mat
 import org.junit.Before;
 import org.junit.Test;
 
-import java.io.File;
-
 public class NaiveBayesTest extends MahoutTestCase {
 
   private Configuration conf;
@@ -80,7 +80,7 @@ public class NaiveBayesTest extends Maho
       writer.append(LABEL_NOT_STOLEN, trainingInstance(COLOR_RED, TYPE_SUV, ORIGIN_IMPORTED));
       writer.append(LABEL_STOLEN, trainingInstance(COLOR_RED, TYPE_SPORTS, ORIGIN_IMPORTED));
     } finally {
-      Closeables.close(writer, true);
+      Closeables.close(writer, false);
     }
   }
 

Modified: mahout/trunk/core/src/test/java/org/apache/mahout/classifier/sgd/ModelSerializerTest.java
URL: http://svn.apache.org/viewvc/mahout/trunk/core/src/test/java/org/apache/mahout/classifier/sgd/ModelSerializerTest.java?rev=1491265&r1=1491264&r2=1491265&view=diff
==============================================================================
--- mahout/trunk/core/src/test/java/org/apache/mahout/classifier/sgd/ModelSerializerTest.java (original)
+++ mahout/trunk/core/src/test/java/org/apache/mahout/classifier/sgd/ModelSerializerTest.java Sun Jun  9 18:50:03 2013
@@ -17,6 +17,13 @@
 
 package org.apache.mahout.classifier.sgd;
 
+import java.io.ByteArrayInputStream;
+import java.io.ByteArrayOutputStream;
+import java.io.DataInputStream;
+import java.io.DataOutputStream;
+import java.io.IOException;
+import java.util.Random;
+
 import com.google.common.io.Closeables;
 import org.apache.hadoop.io.Writable;
 import org.apache.mahout.classifier.OnlineLearner;
@@ -24,19 +31,12 @@ import org.apache.mahout.common.MahoutTe
 import org.apache.mahout.common.RandomUtils;
 import org.apache.mahout.math.DenseVector;
 import org.apache.mahout.math.Vector;
-import org.apache.mahout.math.function.Functions;
 import org.apache.mahout.math.function.DoubleFunction;
+import org.apache.mahout.math.function.Functions;
 import org.apache.mahout.math.stats.GlobalOnlineAuc;
 import org.apache.mahout.math.stats.OnlineAuc;
 import org.junit.Test;
 
-import java.io.ByteArrayInputStream;
-import java.io.ByteArrayOutputStream;
-import java.io.DataInputStream;
-import java.io.DataOutputStream;
-import java.io.IOException;
-import java.util.Random;
-
 public final class ModelSerializerTest extends MahoutTestCase {
 
   private static <T extends Writable> T roundTrip(T m, Class<T> clazz) throws IOException {
@@ -45,7 +45,7 @@ public final class ModelSerializerTest e
     try {
       PolymorphicWritable.write(dos, m);
     } finally {
-      Closeables.close(dos, true);
+      Closeables.close(dos, false);
     }
     return PolymorphicWritable.read(new DataInputStream(new ByteArrayInputStream(buf.toByteArray())), clazz);
   }

Modified: mahout/trunk/core/src/test/java/org/apache/mahout/clustering/ClusteringTestUtils.java
URL: http://svn.apache.org/viewvc/mahout/trunk/core/src/test/java/org/apache/mahout/clustering/ClusteringTestUtils.java?rev=1491265&r1=1491264&r2=1491265&view=diff
==============================================================================
--- mahout/trunk/core/src/test/java/org/apache/mahout/clustering/ClusteringTestUtils.java (original)
+++ mahout/trunk/core/src/test/java/org/apache/mahout/clustering/ClusteringTestUtils.java Sun Jun  9 18:50:03 2013
@@ -17,6 +17,9 @@
 
 package org.apache.mahout.clustering;
 
+import java.io.IOException;
+import java.util.Random;
+
 import com.google.common.base.Preconditions;
 import com.google.common.io.Closeables;
 import org.apache.hadoop.conf.Configuration;
@@ -34,9 +37,6 @@ import org.apache.mahout.math.VectorWrit
 import org.apache.mahout.math.function.DoubleFunction;
 import org.apache.mahout.math.stats.Sampler;
 
-import java.io.IOException;
-import java.util.Random;
-
 public final class ClusteringTestUtils {
 
   private ClusteringTestUtils() {
@@ -65,7 +65,7 @@ public final class ClusteringTestUtils {
         writer.append(intWritable ? new IntWritable(recNum++) : new LongWritable(recNum++), point);
       }
     } finally {
-      Closeables.close(writer, true);
+      Closeables.close(writer, false);
     }
   }
 

Modified: mahout/trunk/core/src/test/java/org/apache/mahout/clustering/dirichlet/TestMapReduce.java
URL: http://svn.apache.org/viewvc/mahout/trunk/core/src/test/java/org/apache/mahout/clustering/dirichlet/TestMapReduce.java?rev=1491265&r1=1491264&r2=1491265&view=diff
==============================================================================
--- mahout/trunk/core/src/test/java/org/apache/mahout/clustering/dirichlet/TestMapReduce.java (original)
+++ mahout/trunk/core/src/test/java/org/apache/mahout/clustering/dirichlet/TestMapReduce.java Sun Jun  9 18:50:03 2013
@@ -256,7 +256,7 @@ public final class TestMapReduce extends
     try {
       inverseCovarianceMatrix.write(out);
     } finally {
-      Closeables.close(out, true);
+      Closeables.close(out, false);
     }
     
     Path meanVectorFile = new Path(getTestTempDirPath("mahalanobis"), "MahalanobisDistanceMeasureMeanVectorFile");
@@ -267,7 +267,7 @@ public final class TestMapReduce extends
     try {
       meanVectorWritable.write(out);
     } finally {
-      Closeables.close(out, true);
+      Closeables.close(out, false);
     }
     
     conf.set("MahalanobisDistanceMeasure.maxtrixClass", MatrixWritable.class.getName());

Modified: mahout/trunk/core/src/test/java/org/apache/mahout/clustering/fuzzykmeans/TestFuzzyKmeansClustering.java
URL: http://svn.apache.org/viewvc/mahout/trunk/core/src/test/java/org/apache/mahout/clustering/fuzzykmeans/TestFuzzyKmeansClustering.java?rev=1491265&r1=1491264&r2=1491265&view=diff
==============================================================================
--- mahout/trunk/core/src/test/java/org/apache/mahout/clustering/fuzzykmeans/TestFuzzyKmeansClustering.java (original)
+++ mahout/trunk/core/src/test/java/org/apache/mahout/clustering/fuzzykmeans/TestFuzzyKmeansClustering.java Sun Jun  9 18:50:03 2013
@@ -83,7 +83,7 @@ public final class TestFuzzyKmeansCluste
           writer.append(new Text(cluster.getIdentifier()), cluster);
         }
       } finally {
-        Closeables.close(writer, true);
+        Closeables.close(writer, false);
       }
 
       // now run the Job using the run() command line options.
@@ -156,7 +156,7 @@ public final class TestFuzzyKmeansCluste
 
         }
       } finally {
-        Closeables.close(writer, true);
+        Closeables.close(writer, false);
       }
 
       // now run the Job using the run() command line options.

Modified: mahout/trunk/core/src/test/java/org/apache/mahout/clustering/kmeans/TestKmeansClustering.java
URL: http://svn.apache.org/viewvc/mahout/trunk/core/src/test/java/org/apache/mahout/clustering/kmeans/TestKmeansClustering.java?rev=1491265&r1=1491264&r2=1491265&view=diff
==============================================================================
--- mahout/trunk/core/src/test/java/org/apache/mahout/clustering/kmeans/TestKmeansClustering.java (original)
+++ mahout/trunk/core/src/test/java/org/apache/mahout/clustering/kmeans/TestKmeansClustering.java Sun Jun  9 18:50:03 2013
@@ -146,7 +146,7 @@ public final class TestKmeansClustering 
           writer.append(new Text(cluster.getIdentifier()), cluster);
         }
       } finally {
-        Closeables.close(writer, true);
+        Closeables.close(writer, false);
       }
       // now run the Job
       Path outputPath = getTestTempDirPath("output");
@@ -203,7 +203,7 @@ public final class TestKmeansClustering 
           writer.append(new Text(cluster.getIdentifier()), cluster);
         }
       } finally {
-        Closeables.close(writer, true);
+        Closeables.close(writer, false);
       }
       // now run the Job
       Path outputPath = getTestTempDirPath("output");

Modified: mahout/trunk/core/src/test/java/org/apache/mahout/common/MahoutTestCase.java
URL: http://svn.apache.org/viewvc/mahout/trunk/core/src/test/java/org/apache/mahout/common/MahoutTestCase.java?rev=1491265&r1=1491264&r2=1491265&view=diff
==============================================================================
--- mahout/trunk/core/src/test/java/org/apache/mahout/common/MahoutTestCase.java (original)
+++ mahout/trunk/core/src/test/java/org/apache/mahout/common/MahoutTestCase.java Sun Jun  9 18:50:03 2013
@@ -142,7 +142,7 @@ public abstract class MahoutTestCase ext
         writer.write('\n');
       }
     } finally {
-      Closeables.close(writer, true);
+      Closeables.close(writer, false);
     }
   }
 }

Modified: mahout/trunk/core/src/test/java/org/apache/mahout/fpm/pfpgrowth/FPGrowthTest.java
URL: http://svn.apache.org/viewvc/mahout/trunk/core/src/test/java/org/apache/mahout/fpm/pfpgrowth/FPGrowthTest.java?rev=1491265&r1=1491264&r2=1491265&view=diff
==============================================================================
--- mahout/trunk/core/src/test/java/org/apache/mahout/fpm/pfpgrowth/FPGrowthTest.java (original)
+++ mahout/trunk/core/src/test/java/org/apache/mahout/fpm/pfpgrowth/FPGrowthTest.java Sun Jun  9 18:50:03 2013
@@ -72,7 +72,7 @@ public final class FPGrowthTest extends 
         new StringOutputConverter(new SequenceFileOutputCollector<Text,TopKStringPatterns>(writer)),
         new ContextStatusUpdater(null));
     } finally {
-      Closeables.close(writer, true);
+      Closeables.close(writer, false);
     }
 
     List<Pair<String, TopKStringPatterns>> frequentPatterns = FPGrowth.readFrequentPattern(conf, path);
@@ -115,7 +115,7 @@ public final class FPGrowthTest extends 
           new StringOutputConverter(new SequenceFileOutputCollector<Text,TopKStringPatterns>(writer)),
           new ContextStatusUpdater(null));
     } finally {
-      Closeables.close(writer, true);
+      Closeables.close(writer, false);
     }
 
     List<Pair<String, TopKStringPatterns>> frequentPatterns = FPGrowth.readFrequentPattern(conf, path);
@@ -153,7 +153,7 @@ public final class FPGrowthTest extends 
           new StringOutputConverter(new SequenceFileOutputCollector<Text,TopKStringPatterns>(writer)),
           new ContextStatusUpdater(null));
     } finally {
-      Closeables.close(writer, true);
+      Closeables.close(writer, false);
     }
 
     List<Pair<String, TopKStringPatterns>> frequentPatterns = FPGrowth.readFrequentPattern(conf, path);

Modified: mahout/trunk/core/src/test/java/org/apache/mahout/fpm/pfpgrowth/FPGrowthTest2.java
URL: http://svn.apache.org/viewvc/mahout/trunk/core/src/test/java/org/apache/mahout/fpm/pfpgrowth/FPGrowthTest2.java?rev=1491265&r1=1491264&r2=1491265&view=diff
==============================================================================
--- mahout/trunk/core/src/test/java/org/apache/mahout/fpm/pfpgrowth/FPGrowthTest2.java (original)
+++ mahout/trunk/core/src/test/java/org/apache/mahout/fpm/pfpgrowth/FPGrowthTest2.java Sun Jun  9 18:50:03 2013
@@ -72,7 +72,7 @@ public final class FPGrowthTest2 extends
         new StringOutputConverter(new SequenceFileOutputCollector<Text,TopKStringPatterns>(writer)),
         new ContextStatusUpdater(null));
     } finally {
-      Closeables.close(writer, true);
+      Closeables.close(writer, false);
     }
 
     List<Pair<String, TopKStringPatterns>> frequentPatterns = FPGrowthObj.readFrequentPattern(conf, path);
@@ -115,7 +115,7 @@ public final class FPGrowthTest2 extends
           new StringOutputConverter(new SequenceFileOutputCollector<Text,TopKStringPatterns>(writer)),
           new ContextStatusUpdater(null));
     } finally {
-      Closeables.close(writer, true);
+      Closeables.close(writer, false);
     }
 
     List<Pair<String, TopKStringPatterns>> frequentPatterns = FPGrowthObj.readFrequentPattern(conf, path);
@@ -153,7 +153,7 @@ public final class FPGrowthTest2 extends
           new StringOutputConverter(new SequenceFileOutputCollector<Text,TopKStringPatterns>(writer)),
           new ContextStatusUpdater(null));
     } finally {
-      Closeables.close(writer, true);
+      Closeables.close(writer, false);
     }
 
     List<Pair<String, TopKStringPatterns>> frequentPatterns = FPGrowthObj.readFrequentPattern(conf, path);

Modified: mahout/trunk/core/src/test/java/org/apache/mahout/fpm/pfpgrowth/PFPGrowthRetailDataTest.java
URL: http://svn.apache.org/viewvc/mahout/trunk/core/src/test/java/org/apache/mahout/fpm/pfpgrowth/PFPGrowthRetailDataTest.java?rev=1491265&r1=1491264&r2=1491265&view=diff
==============================================================================
--- mahout/trunk/core/src/test/java/org/apache/mahout/fpm/pfpgrowth/PFPGrowthRetailDataTest.java (original)
+++ mahout/trunk/core/src/test/java/org/apache/mahout/fpm/pfpgrowth/PFPGrowthRetailDataTest.java Sun Jun  9 18:50:03 2013
@@ -84,7 +84,7 @@ public class PFPGrowthRetailDataTest ext
       }
       
     } finally {
-      Closeables.close(writer, true);
+      Closeables.close(writer, false);
     }
   }
   

Modified: mahout/trunk/core/src/test/java/org/apache/mahout/fpm/pfpgrowth/PFPGrowthRetailDataTest2.java
URL: http://svn.apache.org/viewvc/mahout/trunk/core/src/test/java/org/apache/mahout/fpm/pfpgrowth/PFPGrowthRetailDataTest2.java?rev=1491265&r1=1491264&r2=1491265&view=diff
==============================================================================
--- mahout/trunk/core/src/test/java/org/apache/mahout/fpm/pfpgrowth/PFPGrowthRetailDataTest2.java (original)
+++ mahout/trunk/core/src/test/java/org/apache/mahout/fpm/pfpgrowth/PFPGrowthRetailDataTest2.java Sun Jun  9 18:50:03 2013
@@ -84,7 +84,7 @@ public class PFPGrowthRetailDataTest2 ex
       }
       
     } finally {
-      Closeables.close(writer, true);
+      Closeables.close(writer, false);
     }
   }
   

Modified: mahout/trunk/core/src/test/java/org/apache/mahout/fpm/pfpgrowth/PFPGrowthRetailDataTestVs.java
URL: http://svn.apache.org/viewvc/mahout/trunk/core/src/test/java/org/apache/mahout/fpm/pfpgrowth/PFPGrowthRetailDataTestVs.java?rev=1491265&r1=1491264&r2=1491265&view=diff
==============================================================================
--- mahout/trunk/core/src/test/java/org/apache/mahout/fpm/pfpgrowth/PFPGrowthRetailDataTestVs.java (original)
+++ mahout/trunk/core/src/test/java/org/apache/mahout/fpm/pfpgrowth/PFPGrowthRetailDataTestVs.java Sun Jun  9 18:50:03 2013
@@ -94,7 +94,7 @@ public final class PFPGrowthRetailDataTe
       }
       
     } finally {
-      Closeables.close(writer, true);
+      Closeables.close(writer, false);
     }
   }
   

Modified: mahout/trunk/core/src/test/java/org/apache/mahout/fpm/pfpgrowth/PFPGrowthSynthDataTest2.java
URL: http://svn.apache.org/viewvc/mahout/trunk/core/src/test/java/org/apache/mahout/fpm/pfpgrowth/PFPGrowthSynthDataTest2.java?rev=1491265&r1=1491264&r2=1491265&view=diff
==============================================================================
--- mahout/trunk/core/src/test/java/org/apache/mahout/fpm/pfpgrowth/PFPGrowthSynthDataTest2.java (original)
+++ mahout/trunk/core/src/test/java/org/apache/mahout/fpm/pfpgrowth/PFPGrowthSynthDataTest2.java Sun Jun  9 18:50:03 2013
@@ -87,7 +87,7 @@ public class PFPGrowthSynthDataTest2 ext
       }
       
     } finally {
-      Closeables.close(writer, true);
+      Closeables.close(writer, false);
     }
   }
 

Modified: mahout/trunk/core/src/test/java/org/apache/mahout/fpm/pfpgrowth/PFPGrowthTest.java
URL: http://svn.apache.org/viewvc/mahout/trunk/core/src/test/java/org/apache/mahout/fpm/pfpgrowth/PFPGrowthTest.java?rev=1491265&r1=1491264&r2=1491265&view=diff
==============================================================================
--- mahout/trunk/core/src/test/java/org/apache/mahout/fpm/pfpgrowth/PFPGrowthTest.java (original)
+++ mahout/trunk/core/src/test/java/org/apache/mahout/fpm/pfpgrowth/PFPGrowthTest.java Sun Jun  9 18:50:03 2013
@@ -74,7 +74,7 @@ public final class PFPGrowthTest extends
         writer.write("\n");
       }
     } finally {
-      Closeables.close(writer, true);
+      Closeables.close(writer, false);
     }
     
   }

Modified: mahout/trunk/core/src/test/java/org/apache/mahout/fpm/pfpgrowth/PFPGrowthTest2.java
URL: http://svn.apache.org/viewvc/mahout/trunk/core/src/test/java/org/apache/mahout/fpm/pfpgrowth/PFPGrowthTest2.java?rev=1491265&r1=1491264&r2=1491265&view=diff
==============================================================================
--- mahout/trunk/core/src/test/java/org/apache/mahout/fpm/pfpgrowth/PFPGrowthTest2.java (original)
+++ mahout/trunk/core/src/test/java/org/apache/mahout/fpm/pfpgrowth/PFPGrowthTest2.java Sun Jun  9 18:50:03 2013
@@ -75,7 +75,7 @@ public final class PFPGrowthTest2 extend
         writer.write("\n");
       }
     } finally {
-      Closeables.close(writer, true);
+      Closeables.close(writer, false);
     }
     
   }

Modified: mahout/trunk/core/src/test/java/org/apache/mahout/math/MatrixWritableTest.java
URL: http://svn.apache.org/viewvc/mahout/trunk/core/src/test/java/org/apache/mahout/math/MatrixWritableTest.java?rev=1491265&r1=1491264&r2=1491265&view=diff
==============================================================================
--- mahout/trunk/core/src/test/java/org/apache/mahout/math/MatrixWritableTest.java (original)
+++ mahout/trunk/core/src/test/java/org/apache/mahout/math/MatrixWritableTest.java Sun Jun  9 18:50:03 2013
@@ -17,11 +17,6 @@
 
 package org.apache.mahout.math;
 
-import com.google.common.collect.Maps;
-import com.google.common.io.Closeables;
-import org.apache.hadoop.io.Writable;
-import org.junit.Test;
-
 import java.io.ByteArrayInputStream;
 import java.io.ByteArrayOutputStream;
 import java.io.DataInputStream;
@@ -29,6 +24,11 @@ import java.io.DataOutputStream;
 import java.io.IOException;
 import java.util.Map;
 
+import com.google.common.collect.Maps;
+import com.google.common.io.Closeables;
+import org.apache.hadoop.io.Writable;
+import org.junit.Test;
+
 public final class MatrixWritableTest extends MahoutTestCase {
 
 	@Test
@@ -116,7 +116,7 @@ public final class MatrixWritableTest ex
 		try {
 			toWrite.write(dos);
 		} finally {
-			Closeables.close(dos, true);
+			Closeables.close(dos, false);
 		}
 
 		ByteArrayInputStream bais = new ByteArrayInputStream(baos.toByteArray());

Modified: mahout/trunk/core/src/test/java/org/apache/mahout/math/VectorWritableTest.java
URL: http://svn.apache.org/viewvc/mahout/trunk/core/src/test/java/org/apache/mahout/math/VectorWritableTest.java?rev=1491265&r1=1491264&r2=1491265&view=diff
==============================================================================
--- mahout/trunk/core/src/test/java/org/apache/mahout/math/VectorWritableTest.java (original)
+++ mahout/trunk/core/src/test/java/org/apache/mahout/math/VectorWritableTest.java Sun Jun  9 18:50:03 2013
@@ -109,7 +109,7 @@ public final class VectorWritableTest ex
     try {
       toWrite.write(dos);
     } finally {
-      Closeables.close(dos, true);
+      Closeables.close(dos, false);
     }
 
     ByteArrayInputStream bais = new ByteArrayInputStream(baos.toByteArray());

Modified: mahout/trunk/core/src/test/java/org/apache/mahout/math/hadoop/MathHelper.java
URL: http://svn.apache.org/viewvc/mahout/trunk/core/src/test/java/org/apache/mahout/math/hadoop/MathHelper.java?rev=1491265&r1=1491264&r2=1491265&view=diff
==============================================================================
--- mahout/trunk/core/src/test/java/org/apache/mahout/math/hadoop/MathHelper.java (original)
+++ mahout/trunk/core/src/test/java/org/apache/mahout/math/hadoop/MathHelper.java Sun Jun  9 18:50:03 2013
@@ -38,10 +38,9 @@ import org.apache.mahout.math.RandomAcce
 import org.apache.mahout.math.Vector;
 import org.apache.mahout.math.Vector.Element;
 import org.apache.mahout.math.VectorWritable;
-import org.apache.mahout.math.hadoop.DistributedRowMatrix.MatrixEntryWritable;
 import org.apache.mahout.math.map.OpenIntObjectHashMap;
-import org.easymock.IArgumentMatcher;
 import org.easymock.EasyMock;
+import org.easymock.IArgumentMatcher;
 import org.junit.Assert;
 
 /**
@@ -189,7 +188,7 @@ public final class MathHelper {
         writer.append(new IntWritable(n), new VectorWritable(v));
       }
     } finally {
-      Closeables.close(writer, true);
+      Closeables.close(writer, false);
     }
   }
 

Modified: mahout/trunk/core/src/test/java/org/apache/mahout/math/hadoop/stochasticsvd/LocalSSVDPCADenseTest.java
URL: http://svn.apache.org/viewvc/mahout/trunk/core/src/test/java/org/apache/mahout/math/hadoop/stochasticsvd/LocalSSVDPCADenseTest.java?rev=1491265&r1=1491264&r2=1491265&view=diff
==============================================================================
--- mahout/trunk/core/src/test/java/org/apache/mahout/math/hadoop/stochasticsvd/LocalSSVDPCADenseTest.java (original)
+++ mahout/trunk/core/src/test/java/org/apache/mahout/math/hadoop/stochasticsvd/LocalSSVDPCADenseTest.java Sun Jun  9 18:50:03 2013
@@ -103,7 +103,7 @@ public class LocalSSVDPCADenseTest exten
       xi.assign(dv, Functions.PLUS);
     }
     closeables.remove(w);
-    Closeables.close(w, true);
+    Closeables.close(w, false);
 
     // TODO fix test so that 1.0/m works as intended!
     xi.assign(Functions.mult(1 / m));

Modified: mahout/trunk/core/src/test/java/org/apache/mahout/math/hadoop/stochasticsvd/LocalSSVDSolverSparseSequentialTest.java
URL: http://svn.apache.org/viewvc/mahout/trunk/core/src/test/java/org/apache/mahout/math/hadoop/stochasticsvd/LocalSSVDSolverSparseSequentialTest.java?rev=1491265&r1=1491264&r2=1491265&view=diff
==============================================================================
--- mahout/trunk/core/src/test/java/org/apache/mahout/math/hadoop/stochasticsvd/LocalSSVDSolverSparseSequentialTest.java (original)
+++ mahout/trunk/core/src/test/java/org/apache/mahout/math/hadoop/stochasticsvd/LocalSSVDSolverSparseSequentialTest.java Sun Jun  9 18:50:03 2013
@@ -115,7 +115,7 @@ public class LocalSSVDSolverSparseSequen
       w.append(roww, vw);
     }
     closeables.remove(w);
-    Closeables.close(w, true);
+    Closeables.close(w, false);
 
     FileSystem fs = FileSystem.get(aLocPath.toUri(), conf);
 

Modified: mahout/trunk/core/src/test/java/org/apache/mahout/math/stats/entropy/ConditionalEntropyTest.java
URL: http://svn.apache.org/viewvc/mahout/trunk/core/src/test/java/org/apache/mahout/math/stats/entropy/ConditionalEntropyTest.java?rev=1491265&r1=1491264&r2=1491265&view=diff
==============================================================================
--- mahout/trunk/core/src/test/java/org/apache/mahout/math/stats/entropy/ConditionalEntropyTest.java (original)
+++ mahout/trunk/core/src/test/java/org/apache/mahout/math/stats/entropy/ConditionalEntropyTest.java Sun Jun  9 18:50:03 2013
@@ -17,6 +17,8 @@
 
 package org.apache.mahout.math.stats.entropy;
 
+import java.util.Iterator;
+
 import com.google.common.io.Closeables;
 import org.apache.hadoop.conf.Configuration;
 import org.apache.hadoop.fs.FileSystem;
@@ -32,8 +34,6 @@ import org.apache.mahout.common.iterator
 import org.apache.mahout.common.iterator.sequencefile.SequenceFileDirValueIterator;
 import org.junit.Test;
 
-import java.util.Iterator;
-
 public final class ConditionalEntropyTest extends MahoutTestCase {
 
   @Test
@@ -53,7 +53,7 @@ public final class ConditionalEntropyTes
         writer.append(new Text(keys[i]), new Text(values[i]));
       }
     } finally {
-      Closeables.close(writer, true);
+      Closeables.close(writer, false);
     }
 
     // run the job

Modified: mahout/trunk/core/src/test/java/org/apache/mahout/math/stats/entropy/EntropyTest.java
URL: http://svn.apache.org/viewvc/mahout/trunk/core/src/test/java/org/apache/mahout/math/stats/entropy/EntropyTest.java?rev=1491265&r1=1491264&r2=1491265&view=diff
==============================================================================
--- mahout/trunk/core/src/test/java/org/apache/mahout/math/stats/entropy/EntropyTest.java (original)
+++ mahout/trunk/core/src/test/java/org/apache/mahout/math/stats/entropy/EntropyTest.java Sun Jun  9 18:50:03 2013
@@ -17,6 +17,8 @@
 
 package org.apache.mahout.math.stats.entropy;
 
+import java.util.Iterator;
+
 import com.google.common.io.Closeables;
 import org.apache.hadoop.conf.Configuration;
 import org.apache.hadoop.fs.FileSystem;
@@ -32,8 +34,6 @@ import org.apache.mahout.common.iterator
 import org.apache.mahout.common.iterator.sequencefile.SequenceFileDirValueIterator;
 import org.junit.Test;
 
-import java.util.Iterator;
-
 public final class EntropyTest extends MahoutTestCase {
 
   @Test
@@ -68,7 +68,7 @@ public final class EntropyTest extends M
 
       }
     } finally {
-      Closeables.close(writer, true);
+      Closeables.close(writer, false);
     }
 
     // run the job

Modified: mahout/trunk/core/src/test/java/org/apache/mahout/math/stats/entropy/InformationGainRatioTest.java
URL: http://svn.apache.org/viewvc/mahout/trunk/core/src/test/java/org/apache/mahout/math/stats/entropy/InformationGainRatioTest.java?rev=1491265&r1=1491264&r2=1491265&view=diff
==============================================================================
--- mahout/trunk/core/src/test/java/org/apache/mahout/math/stats/entropy/InformationGainRatioTest.java (original)
+++ mahout/trunk/core/src/test/java/org/apache/mahout/math/stats/entropy/InformationGainRatioTest.java Sun Jun  9 18:50:03 2013
@@ -45,7 +45,7 @@ public final class InformationGainRatioT
         writer.append(new Text(keys[i]), new Text(values[i]));
       }
     } finally {
-      Closeables.close(writer, true);
+      Closeables.close(writer, false);
     }
 
     // run the job

Modified: mahout/trunk/core/src/test/java/org/apache/mahout/math/stats/entropy/InformationGainTest.java
URL: http://svn.apache.org/viewvc/mahout/trunk/core/src/test/java/org/apache/mahout/math/stats/entropy/InformationGainTest.java?rev=1491265&r1=1491264&r2=1491265&view=diff
==============================================================================
--- mahout/trunk/core/src/test/java/org/apache/mahout/math/stats/entropy/InformationGainTest.java (original)
+++ mahout/trunk/core/src/test/java/org/apache/mahout/math/stats/entropy/InformationGainTest.java Sun Jun  9 18:50:03 2013
@@ -45,7 +45,7 @@ public final class InformationGainTest e
         writer.append(new Text(keys[i]), new Text(values[i]));
       }
     } finally {
-      Closeables.close(writer, true);
+      Closeables.close(writer, false);
     }
 
     // run the job

Modified: mahout/trunk/core/src/test/java/org/apache/mahout/vectorizer/DictionaryVectorizerTest.java
URL: http://svn.apache.org/viewvc/mahout/trunk/core/src/test/java/org/apache/mahout/vectorizer/DictionaryVectorizerTest.java?rev=1491265&r1=1491264&r2=1491265&view=diff
==============================================================================
--- mahout/trunk/core/src/test/java/org/apache/mahout/vectorizer/DictionaryVectorizerTest.java (original)
+++ mahout/trunk/core/src/test/java/org/apache/mahout/vectorizer/DictionaryVectorizerTest.java Sun Jun  9 18:50:03 2013
@@ -69,7 +69,7 @@ public final class DictionaryVectorizerT
         writer.append(new Text("Document::ID::" + i), new Text(gen.getRandomDocument()));
       }
     } finally {
-      Closeables.close(writer, true);
+      Closeables.close(writer, false);
     }
   }
   

Modified: mahout/trunk/core/src/test/java/org/apache/mahout/vectorizer/DocumentProcessorTest.java
URL: http://svn.apache.org/viewvc/mahout/trunk/core/src/test/java/org/apache/mahout/vectorizer/DocumentProcessorTest.java?rev=1491265&r1=1491264&r2=1491265&view=diff
==============================================================================
--- mahout/trunk/core/src/test/java/org/apache/mahout/vectorizer/DocumentProcessorTest.java (original)
+++ mahout/trunk/core/src/test/java/org/apache/mahout/vectorizer/DocumentProcessorTest.java Sun Jun  9 18:50:03 2013
@@ -17,6 +17,8 @@
 
 package org.apache.mahout.vectorizer;
 
+import java.util.Arrays;
+
 import com.google.common.io.Closeables;
 import org.apache.hadoop.conf.Configuration;
 import org.apache.hadoop.fs.FileStatus;
@@ -24,15 +26,13 @@ import org.apache.hadoop.fs.FileSystem;
 import org.apache.hadoop.fs.Path;
 import org.apache.hadoop.io.SequenceFile;
 import org.apache.hadoop.io.Text;
+import org.apache.lucene.analysis.standard.StandardAnalyzer;
 import org.apache.mahout.common.ClassUtils;
 import org.apache.mahout.common.MahoutTestCase;
 import org.apache.mahout.common.StringTuple;
 import org.apache.mahout.common.iterator.sequencefile.PathFilters;
 import org.junit.Test;
 
-import java.util.Arrays;
-import org.apache.lucene.analysis.standard.StandardAnalyzer;
-
 /**
  * Tests tokenizing of {@link SequenceFile}s containing document ID and text (both as {@link Text})
  * by the {@link DocumentProcessor} into {@link SequenceFile}s of document ID and tokens (as
@@ -57,7 +57,7 @@ public class DocumentProcessorTest exten
       String text2 = "and another one";
       writer.append(new Text(documentId2), new Text(text2));
     } finally {
-      Closeables.close(writer, true);
+      Closeables.close(writer, false);
     }
 
     DocumentProcessor.tokenizeDocuments(input, StandardAnalyzer.class, output, configuration);

Modified: mahout/trunk/core/src/test/java/org/apache/mahout/vectorizer/EncodedVectorsFromSequenceFilesTest.java
URL: http://svn.apache.org/viewvc/mahout/trunk/core/src/test/java/org/apache/mahout/vectorizer/EncodedVectorsFromSequenceFilesTest.java?rev=1491265&r1=1491264&r2=1491265&view=diff
==============================================================================
--- mahout/trunk/core/src/test/java/org/apache/mahout/vectorizer/EncodedVectorsFromSequenceFilesTest.java (original)
+++ mahout/trunk/core/src/test/java/org/apache/mahout/vectorizer/EncodedVectorsFromSequenceFilesTest.java Sun Jun  9 18:50:03 2013
@@ -17,6 +17,9 @@
 
 package org.apache.mahout.vectorizer;
 
+import java.util.LinkedList;
+import java.util.List;
+
 import com.google.common.io.Closeables;
 import org.apache.hadoop.conf.Configuration;
 import org.apache.hadoop.fs.FileSystem;
@@ -35,9 +38,6 @@ import org.apache.mahout.math.VectorWrit
 import org.junit.Before;
 import org.junit.Test;
 
-import java.util.LinkedList;
-import java.util.List;
-
 public class EncodedVectorsFromSequenceFilesTest extends MahoutTestCase {
 
   private static final int NUM_DOCS = 100;
@@ -63,7 +63,7 @@ public class EncodedVectorsFromSequenceF
         writer.append(new Text("Document::ID::" + i), new Text(gen.getRandomDocument()));
       }
     } finally {
-      Closeables.close(writer, true);
+      Closeables.close(writer, false);
     }
   }
   

Modified: mahout/trunk/core/src/test/java/org/apache/mahout/vectorizer/SparseVectorsFromSequenceFilesTest.java
URL: http://svn.apache.org/viewvc/mahout/trunk/core/src/test/java/org/apache/mahout/vectorizer/SparseVectorsFromSequenceFilesTest.java?rev=1491265&r1=1491264&r2=1491265&view=diff
==============================================================================
--- mahout/trunk/core/src/test/java/org/apache/mahout/vectorizer/SparseVectorsFromSequenceFilesTest.java (original)
+++ mahout/trunk/core/src/test/java/org/apache/mahout/vectorizer/SparseVectorsFromSequenceFilesTest.java Sun Jun  9 18:50:03 2013
@@ -58,7 +58,7 @@ public class SparseVectorsFromSequenceFi
         writer.append(new Text("Document::ID::" + i), new Text(gen.getRandomDocument()));
       }
     } finally {
-      Closeables.close(writer, true);
+      Closeables.close(writer, false);
     }
   }
 
@@ -102,7 +102,7 @@ public class SparseVectorsFromSequenceFi
         writer.append(new Text("Document::ID::" + i), new Text(docs[i]));
       }
     } finally {
-      Closeables.close(writer, true);
+      Closeables.close(writer, false);
     }
     Path outPath = runTest(false, false, false, 2, docs.length);
     Path tfidfVectors = new Path(outPath, "tfidf-vectors");
@@ -139,7 +139,7 @@ public class SparseVectorsFromSequenceFi
         writer.append(new Text("Document::ID::" + i), new Text(docs[i]));
       }
     } finally {
-      Closeables.close(writer, true);
+      Closeables.close(writer, false);
     }
     Path outPath = runTest(true, false, false, 2, docs.length);
     Path tfVectors = new Path(outPath, "tf-vectors");

Modified: mahout/trunk/core/src/test/java/org/apache/mahout/vectorizer/collocations/llr/GramKeyTest.java
URL: http://svn.apache.org/viewvc/mahout/trunk/core/src/test/java/org/apache/mahout/vectorizer/collocations/llr/GramKeyTest.java?rev=1491265&r1=1491264&r2=1491265&view=diff
==============================================================================
--- mahout/trunk/core/src/test/java/org/apache/mahout/vectorizer/collocations/llr/GramKeyTest.java (original)
+++ mahout/trunk/core/src/test/java/org/apache/mahout/vectorizer/collocations/llr/GramKeyTest.java Sun Jun  9 18:50:03 2013
@@ -85,7 +85,7 @@ public final class GramKeyTest extends M
     try {
       two.write(out);
     } finally {
-      Closeables.close(out, true);
+      Closeables.close(out, false);
     }
     
     byte[] b = bout.toByteArray();

Modified: mahout/trunk/examples/src/main/java/org/apache/mahout/cf/taste/example/bookcrossing/BookCrossingDataModel.java
URL: http://svn.apache.org/viewvc/mahout/trunk/examples/src/main/java/org/apache/mahout/cf/taste/example/bookcrossing/BookCrossingDataModel.java?rev=1491265&r1=1491264&r2=1491265&view=diff
==============================================================================
--- mahout/trunk/examples/src/main/java/org/apache/mahout/cf/taste/example/bookcrossing/BookCrossingDataModel.java (original)
+++ mahout/trunk/examples/src/main/java/org/apache/mahout/cf/taste/example/bookcrossing/BookCrossingDataModel.java Sun Jun  9 18:50:03 2013
@@ -86,7 +86,7 @@ public final class BookCrossingDataModel
       resultFile.delete();
       throw ioe;
     } finally {
-      Closeables.close(writer, true);
+      Closeables.close(writer, false);
     }
     return resultFile;
   }



Mime
View raw message