Repository: flink Updated Branches: refs/heads/master 1a578657d -> c21ecaed2
[FLINK-5032] Fix CsvOutputFormatTest on Windows OS This closes #2769. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c21ecaed Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/c21ecaed Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/c21ecaed Branch: refs/heads/master Commit: c21ecaed2456a390cc612622b438dca0ce26b9ec Parents: 1a57865 Author: Boris Osipov <[email protected]> Authored: Tue Nov 8 09:35:04 2016 +0300 Committer: zentol <[email protected]> Committed: Tue Nov 8 14:00:14 2016 +0100 ---------------------------------------------------------------------- .../java/org/apache/flink/api/java/io/CsvOutputFormatTest.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/c21ecaed/flink-java/src/test/java/org/apache/flink/api/java/io/CsvOutputFormatTest.java ---------------------------------------------------------------------- diff --git a/flink-java/src/test/java/org/apache/flink/api/java/io/CsvOutputFormatTest.java b/flink-java/src/test/java/org/apache/flink/api/java/io/CsvOutputFormatTest.java index 006f940..a9288c6 100644 --- a/flink-java/src/test/java/org/apache/flink/api/java/io/CsvOutputFormatTest.java +++ b/flink-java/src/test/java/org/apache/flink/api/java/io/CsvOutputFormatTest.java @@ -37,16 +37,16 @@ import java.util.List; public class CsvOutputFormatTest { private String path = null; + private CsvOutputFormat<Tuple3<String, String, Integer>> csvOutputFormat; @Before public void createFile() throws Exception { path = File.createTempFile("csv_output_test_file",".csv").getAbsolutePath(); + csvOutputFormat = new CsvOutputFormat<>(new Path(path)); } @Test public void testNullAllow() throws Exception { - - CsvOutputFormat<Tuple3<String, String, Integer>> csvOutputFormat = new CsvOutputFormat<>(new Path(path)); csvOutputFormat.setWriteMode(FileSystem.WriteMode.OVERWRITE); csvOutputFormat.setOutputDirectoryMode(FileOutputFormat.OutputDirectoryMode.PARONLY); csvOutputFormat.setAllowNullValues(true); @@ -63,7 +63,6 @@ public class CsvOutputFormatTest { @Test(expected = RuntimeException.class) public void testNullDisallowOnDefault() throws Exception { - CsvOutputFormat<Tuple3<String, String, Integer>> csvOutputFormat = new CsvOutputFormat<>(new Path(path)); csvOutputFormat.setWriteMode(FileSystem.WriteMode.OVERWRITE); csvOutputFormat.setOutputDirectoryMode(FileOutputFormat.OutputDirectoryMode.PARONLY); csvOutputFormat.open(0, 1); @@ -73,6 +72,7 @@ public class CsvOutputFormatTest { @After public void cleanUp() throws IOException { + csvOutputFormat.close(); Files.deleteIfExists(Paths.get(path)); }
