OutputFormat unit test discard existing temp files by default.

bbejeck · Mar 3, 2014 · 8311ebc · 8311ebc
1 parent 3a63443
commit 8311ebc
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 4 deletions.
diff --git a/stratosphere-core/src/main/java/eu/stratosphere/api/common/io/FormatUtil.java b/stratosphere-core/src/main/java/eu/stratosphere/api/common/io/FormatUtil.java
@@ -25,6 +25,7 @@
 import eu.stratosphere.core.fs.FileInputSplit;
 import eu.stratosphere.core.fs.FileStatus;
 import eu.stratosphere.core.fs.FileSystem;
+import eu.stratosphere.core.fs.FileSystem.WriteMode;
 import eu.stratosphere.core.fs.Path;
 import eu.stratosphere.core.io.InputSplit;
 import eu.stratosphere.util.ReflectionUtil;
@@ -151,6 +152,7 @@ public static <T, F extends FileOutputFormat<? extends T>> F openOutput(
  final F outputFormat = ReflectionUtil.newInstance(outputFormatClass);
  outputFormat.setOutputFilePath(new Path(path));
  outputFormat.setOpenTimeout(0);
+ outputFormat.setWriteMode(WriteMode.OVERWRITE);
 
  configuration = configuration == null ? new Configuration() : configuration;
 

diff --git a/stratosphere-core/src/test/java/eu/stratosphere/api/common/io/SequentialFormatTest.java b/stratosphere-core/src/test/java/eu/stratosphere/api/common/io/SequentialFormatTest.java
@@ -54,10 +54,6 @@
 public class SequentialFormatTest {
 
  public class InputSplitSorter implements Comparator<FileInputSplit> {
- /*
- * (non-Javadoc)
- * @see java.util.Comparator#compare(java.lang.Object, java.lang.Object)
- */
  @Override
  public int compare(FileInputSplit o1, FileInputSplit o2) {
  int pathOrder = o1.getPath().getName().compareTo(o2.getPath().getName());

diff --git a/stratosphere-java/src/test/java/eu/stratosphere/api/java/record/io/CsvOutputFormatTest.java b/stratosphere-java/src/test/java/eu/stratosphere/api/java/record/io/CsvOutputFormatTest.java
@@ -31,6 +31,7 @@
 import eu.stratosphere.api.java.record.io.CsvOutputFormat;
 import eu.stratosphere.configuration.Configuration;
 import eu.stratosphere.core.fs.Path;
+import eu.stratosphere.core.fs.FileSystem.WriteMode;
 import eu.stratosphere.types.IntValue;
 import eu.stratosphere.types.Record;
 import eu.stratosphere.types.StringValue;
@@ -49,6 +50,7 @@ public class CsvOutputFormatTest {
  public void setup() throws IOException {
  this.tempFile = File.createTempFile("test_output", "tmp");
  this.format.setOutputFilePath(new Path(tempFile.toURI()));
+ this.format.setWriteMode(WriteMode.OVERWRITE);
  }
 
  @After