You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2016/11/08 13:01:16 UTC
flink git commit: [FLINK-5032] Fix CsvOutputFormatTest on Windows OS
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 <bo...@epam.com>
Authored: Tue Nov 8 09:35:04 2016 +0300
Committer: zentol <ch...@apache.org>
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));
}